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