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

AcknowledgeableMessage

A received message which can be acknowledged to prevent re-delivery by the backing message service.

MessageStream

The stream returned by the consume function

Traits

AcknowledgeToken

A token associated with some message received from a message service, used to issue an ack/nack/modify request

Consumer

Message consumers ingest messages from a queue service and present them to the user application as a Stream.

DecodableMessage

Messages which can be decoded from a ValidatedMessage stream.