Make domain and prefix setup cleaner

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
This commit is contained in:
Tomasz Pietrek 2023-01-04 10:48:24 +01:00
parent 94894c465b
commit 97ad52c692
1 changed files with 11 additions and 1 deletions

View File

@ -68,7 +68,17 @@ func (js *jetstreamPubSub) Init(metadata pubsub.Metadata) error {
}
js.l.Debugf("Connected to nats at %s", js.meta.natsURL)
js.jsc, err = js.nc.JetStream(nats.Domain(js.meta.domain), nats.APIPrefix(js.meta.apiPrefix))
jsOpts := []nats.JSOpt{}
if js.meta.domain != "" {
jsOpts = append(jsOpts, nats.Domain(js.meta.domain))
}
if js.meta.apiPrefix != "" {
jsOpts = append(jsOpts, nats.APIPrefix(js.meta.apiPrefix))
}
js.jsc, err = js.nc.JetStream(jsOpts...)
if err != nil {
return err
}