From 240cc725e8dde7bfb54b311fa61cf365b8a26859 Mon Sep 17 00:00:00 2001 From: Nam Huynh Date: Fri, 18 Mar 2022 10:23:22 +0700 Subject: [PATCH] fix pullsub channel name --- jetstream_pubsub.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/jetstream_pubsub.go b/jetstream_pubsub.go index bc2f584..daad7cd 100644 --- a/jetstream_pubsub.go +++ b/jetstream_pubsub.go @@ -45,7 +45,7 @@ func (js JetStream) Subscribe(stream, subject string, cb nats.MsgHandler) (*nats func (js JetStream) PullSubscribe(stream, subject string) (*nats.Subscription, error) { channel := combineStreamAndSubjectName(stream, subject) - sub, err := js.instance.PullSubscribe(channel, subject) + sub, err := js.instance.PullSubscribe(stream, subject) if err != nil { msg := fmt.Sprintf("[NATS JETSTREAM] - pull subscribe subject #%s error: %s", channel, err.Error()) return nil, errors.New(msg)