NAME

Crixa::Queue

VERSION

version 0.05

DESCRIPTION

A class to represent Queues in Crixa.

ATTRIBUTES

name

channel

Required.

METHODS

BUILD

name

The queue name.

channel

The channel this queue is configured for.

check_for_message

Checks the queue for a message. This doesn't block but instead will return undef if the queue is empty.

wait_for_message

Checks the queue for a message and blocks until one appears.

handle_message

Takes a callback and executes the callback when the next message appears in the queue.

publish

Send a new message to this queue.