Package-level declarations
Types
Dispatches each observation to an immutable observer snapshot in iteration order.
The command bus on Redis Streams: a TransportCommandBus over a RedisStreamTransport, with streams from topicConverter. Undecodable entries are reported to messageBusObserver and stay pending (RedisRecordDecodeFailureHandler).
The domain event stream bus on Redis Streams: a TransportDomainEventBus over a RedisStreamTransport, with streams from topicConverter. Undecodable entries are reported to messageBusObserver and stay pending (RedisRecordDecodeFailureHandler).
Message payloads and Throwable instances are deliberately excluded so observers cannot retain sensitive payloads or failure object graphs.
Receives synchronous Redis message-bus recovery and decode observations.
The Redis decode-failure policy: report the record to the observer and the log (without its payload) and leave it pending, so the consumer continues with the next entry.
The state event bus on Redis Streams: a TransportStateEventBus over a RedisStreamTransport, with streams from topicConverter. Undecodable entries are reported to messageBusObserver and stay pending (RedisRecordDecodeFailureHandler).
What the Redis stream bus keeps: stream entries and consumers.
Redis Streams as a Transport: a topic is a stream, a message is one entry whose MESSAGE_FIELD field holds the payload (keys, timestamps and headers are not written).