[Redis] [NATS Jetstream] msg.Ack not working, am I missing something?

[yohanleb]

Hello,

I tried to set up watermill with Redis and Nats Jetstream and the messages I was sending kept going back on my server restart even tho I was doing msg.Ack on every message after logging them:

func handleEvents(messages <-chan *message.Message) {
	for msg := range messages {
		zap.L().Info("message received", zap.Any("msg", msg))
		msg.Ack()
	}
}

I saw an option WorkQueuePolicy that might not be set by default on Nats Jetstream but not sure what's happening for Redis?

Also, I had no issues with RabbitMQ, messages are not coming back after being acknowledged. I'm new to event handling so a bit of help would be appreciated!

Thanks

[yohanleb]

Update, this seems to work for NATS Jetstream:

var subscribeOptions = []nc.SubOpt{
    nc.DeliverNew(),
    nc.AckExplicit(),
}