Package co.cask.cdap.data2.queue

API definition for queue for the txds2 system.

See: Description

Interface Summary

Interface	Description
DequeueResult<T>	Represents result of an dequeue.
QueueClientFactory	Factory for creating QueueProducer and QueueConsumer for different queue.
QueueConsumer	Interface for queue consumer.
QueueProducer	Implementation of this interface enqueues methods should be thread safe.

Class Summary

Class	Description
ConsumerConfig	Contains queue consumer instance configuration.
ConsumerGroupConfig	Contains queue consumer group information.
DequeueResult.Empty	Static helper class for creating empty result of different result type.
ForwardingQueueConsumer	A TransactionAware QueueConsumer that forwards all queue operations to another QueueConsumer and optionally forward transaction operations if the target QueueConsumer is also TransactionAware.
QueueEntry	Defines QueueEntry.

Enum Summary

Enum	Description
DequeueStrategy	Strategy for dequeue.

Package co.cask.cdap.data2.queue Description

API definition for queue for the txds2 system.