fix log typo
This commit is contained in:
parent
fdcdad6b6d
commit
92b0b45ec7
|
@ -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
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue