Module message

Source
Expand description

A wrapped crate::Message with JetStream related methods.

Structs§

Acker
A lightweight struct useful for decoupling message contents and the ability to ack it.
Info
Information about a received message
Message
StreamMessage
A message received directly from the stream, without leveraging a consumer.

Enums§

AckKind
The kinds of response used for acknowledging a processed message.
StreamMessageErrorKind

Type Aliases§

StreamMessageError
Error returned when library is unable to parse message got directly from the stream.