diff --git a/jetstream_pubsub.go b/jetstream_pubsub.go index c4c1aaa..2586eb8 100644 --- a/jetstream_pubsub.go +++ b/jetstream_pubsub.go @@ -53,7 +53,7 @@ func (js JetStream) PullSubscribe(stream, subject, durable, consumer string) (*n info, err := js.instance.AddConsumer(stream, &nats.ConsumerConfig{ Durable: durable, }) - if err != nil { + if err == nil { fmt.Println("CONSUMER INFO", info) } else { fmt.Println("ADD CONSUMER ERROR", err)