From 97ad52c692421d1dc56ba56ca4196a0d4a2e6286 Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Wed, 4 Jan 2023 10:48:24 +0100 Subject: [PATCH] Make domain and prefix setup cleaner Signed-off-by: Tomasz Pietrek --- pubsub/jetstream/jetstream.go | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/pubsub/jetstream/jetstream.go b/pubsub/jetstream/jetstream.go index 51f1f10a0..3965cb0a5 100644 --- a/pubsub/jetstream/jetstream.go +++ b/pubsub/jetstream/jetstream.go @@ -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 }