Ack acknowledges a message. This tells the server that the message was successfully processed and it can move on to the next message.
()
| 351 | // Ack acknowledges a message. This tells the server that the message was |
| 352 | // successfully processed and it can move on to the next message. |
| 353 | func (m *jetStreamMsg) Ack() error { |
| 354 | return m.ackReply(context.Background(), ackAck, false, ackOpts{}) |
| 355 | } |
| 356 | |
| 357 | // DoubleAck acknowledges a message and waits for ack reply from the server. |
| 358 | // While it impacts performance, it is useful for scenarios where |