DoubleAck acknowledges a message and waits for ack reply from the server. While it impacts performance, it is useful for scenarios where message loss is not acceptable.
(ctx context.Context)
| 358 | // While it impacts performance, it is useful for scenarios where |
| 359 | // message loss is not acceptable. |
| 360 | func (m *jetStreamMsg) DoubleAck(ctx context.Context) error { |
| 361 | return m.ackReply(ctx, ackAck, true, ackOpts{}) |
| 362 | } |
| 363 | |
| 364 | // Nak negatively acknowledges a message. This tells the server to |
| 365 | // redeliver the message. |