Chris Prather > Crixa-0.05 > Crixa::Queue

Download:
Crixa-0.05.tar.gz

Dependencies

Annotate this POD

View/Report Bugs
Module Version: 0.05   Source  

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.

syntax highlighting: