Package eu.vstoyanov.natsy.codec
See: Description
-
Object Summary Object Description BinaryCodec Carries a ByteArray unchanged. SkipAndLog Log a warning and drop the message (the default). Throw Fail the flow with a eu.vstoyanov.natsy.exception.NatsyDecodeException, after terminating the message on JetStream. DeadLetterHeaders Headers stamped on every message published by DecodeErrorStrategy.DeadLetter, describing where the message came from and why it could not be decoded. Companion StringCodec Carries a String as raw UTF-8 - no quoting, no escaping, exactly the bytes a nats pubwould send. -
Class Summary Class Description Builder Collects the codecs that override the JSON default, and the Json every derived codec uses. CodecRegistry Decides which MessageCodec carries a given type on and off the wire. DeadLetter Republish the raw undecodable payload to subject, then drop it from this flow. JsonCodec Carries a value as UTF-8 JSON via kotlinx.serialization. -
Interface Summary Interface Description DecodeErrorStrategy What a reader does with a payload it cannot decode. MessageCodec Turns values of one type into bytes on the wire and back.