diff --git a/jetstream/jetstream.go b/jetstream/jetstream.go index 8e000dc..8778e37 100644 --- a/jetstream/jetstream.go +++ b/jetstream/jetstream.go @@ -112,5 +112,6 @@ func (e *responseAndEvent) NakWithDelay(delay time.Duration) error { if e.responseSent { return nil } + e.responseSent = true return e.m.NakWithDelay(delay) }