A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
W
- waitingPullCount() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
- Get the count of waiting pull requests (for pull consumers)
- watch(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch for changes to a specific keyReturns a Flow that emits KeyValueEntry objects whenever the key changes.
- watch() - function in eu.vstoyanov.natsy.jetstream.ObjectStore
- Watch for changes to objects in the bucketReturns a Flow that emits ObjectStoreInfo whenever objects are created, updated, or deleted.
- watchAll() - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch for changes to all keys in the bucketThe watch buffer is unbounded so no revision is dropped on its way to the collector.
- willAutoResume() - function in eu.vstoyanov.natsy.jetstream.model.PauseResponse
- Check if the consumer is scheduled for automatic resume
- WORK_QUEUE - enum entry in eu.vstoyanov.natsy.jetstream.RetentionPolicy
Retain messages for work queue pattern