package consumer
Type Members
- class ConsumedMessage extends AnyRef
The representation of a message consumed from a specific queue.
The representation of a message consumed from a specific queue. Generally used to represent a message already deleted from the queue, since it does not implements the capability to be deleted. (At most once)
See DeletableMessage for getting over control over when a message is considered processed, thus deleted form the source queue.
- class DeletableMessage extends ConsumedMessage
Represents a message consumed with manual delete, meaning that it provides control over when the message is considered processed and wants to be deleted from the source queue so that the next message can be consumed.
Represents a message consumed with manual delete, meaning that it provides control over when the message is considered processed and wants to be deleted from the source queue so that the next message can be consumed.
And that functionality is exposed by the deleteFromQueue method.
- class SqsConsumer extends StrictLogging