From d26c795ecdd848db01d82b8340702778b7b2789b Mon Sep 17 00:00:00 2001
From: me2seeks <me2seeks@gmail.com>
Date: Tue, 20 Jan 2026 13:41:39 +0800
Subject: [PATCH] fix(natsq): use queue stream name in jetstream consumer

---
 natsq/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/natsq/consumer.go b/natsq/consumer.go
index fa55b6e..256640c 100644
--- a/natsq/consumer.go
+++ b/natsq/consumer.go
@@ -133,7 +133,7 @@ func (cm *ConsumerManager) subscribe(queue ConsumerQueue) {
 	ctx := context.Background()
 	if cm.mode == NatJetMode {
 		js, _ := jetstream.New(cm.conn)
-		stream, err := js.Stream(ctx, "ccc")
+		stream, err := js.Stream(ctx, queue.StreamName)
 		if err != nil {
 			log.Fatalf("Error creating stream: %v", err)
 			return