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