From 95dead981a7d5ecc7c2f3e98e1651155ef79f3c1 Mon Sep 17 00:00:00 2001
From: Nam Huynh <namhq.1989@gmail.com>
Date: Fri, 8 Oct 2021 14:45:07 +0700
Subject: [PATCH] fix rule of stream and subject name

---
 queue.go | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/queue.go b/queue.go
index 1730a94..6364efc 100644
--- a/queue.go
+++ b/queue.go
@@ -8,10 +8,12 @@ import (
 )
 
 // QueueSubscribe ...
-func QueueSubscribe(subject, queueName string, cb nats.MsgHandler) error {
-	_, err := natsJS.QueueSubscribe(subject, queueName, cb)
+func QueueSubscribe(stream, subject, queueName string, cb nats.MsgHandler) error {
+	channel := combineStreamAndSubjectName(stream, subject)
+
+	_, err := natsJS.QueueSubscribe(channel, queueName, cb)
 	if err != nil {
-		msg := fmt.Sprintf("queue subscribe with subject %s error: %s", subject, err.Error())
+		msg := fmt.Sprintf("queue subscribe with subject %s error: %s", channel, err.Error())
 		return errors.New(msg)
 	}
 	return nil