From 92b0b45ec738dcadb19210b76611e5a8fb5d8178 Mon Sep 17 00:00:00 2001 From: namhq1989 Date: Thu, 15 Dec 2022 21:23:28 +0700 Subject: [PATCH] fix log typo --- jetstream_pubsub.go | 4 ++-- jetstream_queue.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/jetstream_pubsub.go b/jetstream_pubsub.go index 6569abc..8cc1848 100644 --- a/jetstream_pubsub.go +++ b/jetstream_pubsub.go @@ -30,7 +30,7 @@ func (js JetStream) Subscribe(subject string, cb nats.MsgHandler) (*nats.Subscri } if js.cfg.Debug { - fmt.Printf("[natsio.JetStream] subscribe new message from subject #%s \n", subject) + fmt.Printf("[natsio.JetStream] subscribe to subject #%s \n", subject) } return sub, nil @@ -52,7 +52,7 @@ func (js JetStream) PullSubscribe(subject, consumer string) (*nats.Subscription, } if js.cfg.Debug { - fmt.Printf("[natsio.JetStream] pull subscribe new message from subject #%s \n", subject) + fmt.Printf("[natsio.JetStream] pull subscribe to subject #%s \n", subject) } return sub, nil diff --git a/jetstream_queue.go b/jetstream_queue.go index 1708378..20941ed 100644 --- a/jetstream_queue.go +++ b/jetstream_queue.go @@ -16,7 +16,7 @@ func (js JetStream) QueueSubscribe(subject, queueName string, cb nats.MsgHandler } if js.cfg.Debug { - fmt.Printf("[natsio.JetStream] queue subscribe new message from subject #%s \n", subject) + fmt.Printf("[natsio.JetStream] queue subscribe to subject #%s \n", subject) } return nil