From 8c20a7f7ce0bfc964fcd5dca4e02a36ff25ed42b Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Fri, 7 Jan 2022 16:42:23 +0000
Subject: [PATCH] Use namespaced consumer name

---
 setup/config/config_jetstream.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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) {