New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
js: Prevent sending duplicated Acks #637
Conversation
1db4e05
to
bfd077e
Compare
func (m *Msg) Term() error { | ||
return m.ackReply(AckTerm, false) | ||
} | ||
|
||
// Indicate that this message is being worked on and reset redelkivery timer in the server. | ||
// InProgress indicates that this message is being worked on | ||
// and reset the redelivery timer in the server. | ||
func (m *Msg) InProgress() error { | ||
return m.ackReply(AckProgress, false) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We could issue lots of these, the suppression code would suppress so we may need to look at ack type and the .ackd var.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Updated to skip suppressing acks in case they are to progress report.
5dfda1a
to
b01f159
Compare
Signed-off-by: Waldemar Quevedo <wally@synadia.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Add suppression so that a msg is only attempted to be acked a single time (other than InProgress acks).
Fixes #634
Signed-off-by: Waldemar Quevedo wally@synadia.com