A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
A
- ack() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
- Acknowledge successful processing of the messageTells JetStream that the message has been successfully processed and should not be redelivered.
- ackAll() - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
- Acknowledge every message in the batchThe whole batch is always attempted: stopping at the first failure would leave the rest unacknowledged and waiting to be redelivered.
- AckPolicy - class in eu.vstoyanov.natsy.jetstream.model
- Acknowledgment policy for consumers
- ackUpTo(eu.vstoyanov.natsy.jetstream.JetStreamMessage) - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
- Acknowledge all messages up to and including the specified messageThis is an efficient operation that tells JetStream to acknowledge all messages up to the specified message in a single operation.
- addSuppressed(java.lang.Throwable) - function in kotlin.Throwable
- ALL - enum entry in eu.vstoyanov.natsy.jetstream.model.AckPolicy
Acknowledge all messages up to the current message
- ALL - enum entry in eu.vstoyanov.natsy.jetstream.model.DeliverPolicy
Deliver all available messages
- asFlow() - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
- Convert the batch to a Flow of individual messagesThis allows using Flow operators for processing batch messages.