diff --git a/internal/components/nats/connection.go b/internal/components/nats/connection.go index b582ab1..2dacdd8 100644 --- a/internal/components/nats/connection.go +++ b/internal/components/nats/connection.go @@ -47,10 +47,6 @@ func connectionTailFields() []*service.ConfigField { } type connectionDetails struct { - label string - logger *service.Logger - tlsConf *tls.Config - fs *service.FS poolKey string urls string opts []nats.Option diff --git a/internal/components/nats/request_processor.go b/internal/components/nats/request_processor.go index 002da62..6604a6f 100644 --- a/internal/components/nats/request_processor.go +++ b/internal/components/nats/request_processor.go @@ -148,11 +148,6 @@ func (r *requestReplyProcessor) connect(ctx context.Context) (err error) { } }() - var extraOpts []nats.Option - if r.inboxPrefix != "" { - extraOpts = append(extraOpts, nats.CustomInboxPrefix(r.inboxPrefix)) - } - if r.natsConn, err = pool.Get(ctx, r.pcid, r.connDetails); err != nil { return err }