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 every message from the start of the batch up to and including messageThe run is taken in delivery order, so acknowledging the fifth message acknowledges the first five.
- addSuppressed(java.lang.Throwable) - function in kotlin.Throwable
- ALL - enum entry in eu.vstoyanov.natsy.jetstream.model.AckPolicy
Acknowledging one message also acknowledges every message below it
"All messages with a sequence number less than the message acked are also acknowledged" (jnats
io/nats/client/api/AckPolicy.java:30).- 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.