Module hedwig::consume [−][src]
This is supported on crate feature
consume only.Expand description
Types, traits, and functions necessary to consume messages using hedwig
See the Consumer trait.
Structs
A received message which can be acknowledged to prevent re-delivery by the backing message service.
The stream returned by the consume function
Traits
A token associated with some message received from a message service, used to issue an ack/nack/modify request
Message consumers ingest messages from a queue service and present them to the user application
as a Stream.
Messages which can be decoded from a ValidatedMessage stream.