Queue

Queue interface

Create a new message queue. Message queues allows the application to re-route consumed messages from multiple topic+partitions into one single queue point. This queue point, containing messages from a number of topic+partitions, may then be served by a single consume() method, rather than one per topic+partition combination.

See the Consumer::start(), Consumer::consume(), and Consumer::consumeCallback() methods that take a queue as the first parameter for more information.

Constructors

this
this(Handle handle)

Create Queue object

Destructor

~this
~this()
Undocumented in source.

Meta