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