A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
D
- DeadLetterHeaders - class in eu.vstoyanov.natsy.codec
- Headers stamped on every message published by DecodeErrorStrategy.DeadLetter, describing where the message came from and why it could not be decoded.
- decode(kotlin.ByteArray) - function in eu.vstoyanov.natsy.codec.BinaryCodec
- Decode bytes received from NATS.
- decode(kotlin.ByteArray) - function in eu.vstoyanov.natsy.codec.JsonCodec
- Decode bytes received from NATS.
- decode(kotlin.ByteArray) - function in eu.vstoyanov.natsy.codec.MessageCodec
- Decode bytes received from NATS.
- decode(kotlin.ByteArray) - function in eu.vstoyanov.natsy.codec.StringCodec
- Decode bytes received from NATS.
- DecodeErrorStrategy - class in eu.vstoyanov.natsy.codec
- What a subscription does with a message it cannot decode.
- DecodeErrorStrategy.DeadLetter - class in eu.vstoyanov.natsy.codec.DecodeErrorStrategy
- Republish the raw undecodable message to subject, then drop it from this subscription.
- DecodeErrorStrategy.SkipAndLog - class in eu.vstoyanov.natsy.codec.DecodeErrorStrategy
- Log a warning and drop the message (the default).
- DecodeErrorStrategy.Throw - class in eu.vstoyanov.natsy.codec.DecodeErrorStrategy
- Fail the flow with a eu.vstoyanov.natsy.exception.NatsyDecodeException, after terminating the message on JetStream.
- defaultContentType(java.lang.String) - function in eu.vstoyanov.natsy.codec.CodecRegistry.Builder
- Set the default content type for auto-selection
- delete() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
- Delete the consumerPermanently deletes the consumer.
- delete(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Delete a key (soft delete - places a delete marker)
- delete(java.lang.String,java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Delete a key only if the expected revision matches
- delete(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
- Delete an object from the storeThis marks the object as deleted.
- delete() - function in eu.vstoyanov.natsy.jetstream.StreamContext
- Delete the streamPermanently deletes the stream and all its messages.
- deleteConsumer(java.lang.String,java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
- Delete a consumer by name (convenience method)
- deleteKeyValue(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
- Delete a Key-Value store bucket (convenience method)
- deleteMessage(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamContext
- Delete a specific message by sequence number
- deleteObjectStore(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
- Delete an Object Store bucket (convenience method)
- deleteStream(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
- Delete a stream by name (convenience method)
- DeliverPolicy - class in eu.vstoyanov.natsy.jetstream.model
- Deliver policy determines where to start delivering messages
- DiscardPolicy - class in eu.vstoyanov.natsy.jetstream.model
- Discard policy determines which messages to discard when limits are reached
- drain(kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsKlient
- Gracefully drain the connection, then close itSuspends until the drain has actually finished.