A class to represent Queues in Crixa.
The queue name.
The channel this queue is configured for.
Checks the queue for a message. This doesn't block but instead will return undef if the queue is empty.
Checks the queue for a message and blocks until one appears.
Takes a callback and executes the callback when the next message appears in the queue.
Send a new message to this queue.