Package co.cask.cdap.data2.transaction.queue.inmemory

This package contains in memory implementation of queues.

See: Description

Class Summary

Class	Description
InMemoryQueue	Implementation of an in-memory queue.
InMemoryQueue.ConsumerState	The state of a single consumer, gets modified.
InMemoryQueue.Key	Used as the key of each queue item, composed of a transaction id and a sequence number within the transaction.
InMemoryQueueAdmin	admin for queues in memory.
InMemoryQueueClientFactory
InMemoryQueueConsumer	Consumer for an in-memory queue.
InMemoryQueueProducer	Producer for an in-memory queue.
InMemoryQueueService	Maintains all in-memory queues in the system.
InMemoryStreamAdmin	admin for queues in memory.

Package co.cask.cdap.data2.transaction.queue.inmemory Description

This package contains in memory implementation of queues.