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
- Outbound
Message - An outbound message to be published. Does not contain status or description which are valid only for inbound messages.
- Publish
Message - Used for building customized
publishmessage. - Stream
Message - A message received directly from the stream, without leveraging a consumer.
Enums§
- AckKind
- The kinds of response used for acknowledging a processed message.
- Stream
Message Error Kind
Type Aliases§
- Stream
Message Error - Error returned when library is unable to parse message got directly from the stream.