diff --git a/setup/config/config_jetstream.go b/setup/config/config_jetstream.go index e618e63e5..94e2d88b3 100644 --- a/setup/config/config_jetstream.go +++ b/setup/config/config_jetstream.go @@ -26,7 +26,7 @@ func (c *JetStream) TopicFor(name string) string { } func (c *JetStream) Durable(name string) nats.SubOpt { - return nats.Durable(name) + return nats.Durable(c.TopicFor(name)) } func (c *JetStream) Defaults(generate bool) {