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)