setup/jetstream/helpers.go


1
2
3
4
5
6
7
8
9
10
11
12

package jetstream

import "github.com/nats-io/nats.go"

func WithJetStreamMessage(msg *nats.Msg, f func(msg *nats.Msg) bool) {
	_ = msg.InProgress()
	if f(msg) {
		_ = msg.Ack()
	} else {
		_ = msg.Nak()
	}
}