Search results for "module:Spread::Queue"
Spread::Queue::FIFO - basic FIFO queue
Basic FIFO queue service. Not thread-safe. Logging via Log::Channel....
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
Spread::Queue::Worker - accept Spread::Queue message assignments
A process that declares itself to be a Spread::Queue::Worker will be assigned messages in FIFO fashion by the sqm queue manager. Messages as supported by Spread::Queue are serialized Perl hashes. Spread::Queue does not enforce structure on message co...
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
Spread::Queue::Sender - submit messages to Spread::Queue message queues
A Spread::Queue::Sender can submit messages for queued delivery to the first available Spread::Queue::Worker. The sqm queue manager must be running to receive and route messages. Spread::Queue messages are Perl hashes, serialized by Data::Serializer,...
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
Spread::Queue::Manager - coordinate one-of-many message delivery
The queue manager is responsible for assigning incoming messages (see Spread::Queue::Sender) to registered workers (see Spread::Queue::Worker). When a message comes in, it is assigned to the first available worker, otherwise it is put into a FIFO que...
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
Spread::Queue::ManagedWorker - utility class for Spread::Queue::Manager
Tracks each worker that is registered with the queue manager. Retains worker state. Eventually add activity metrics (# messages assigned, uptime, utilization, etc.). States are: ready - available for task assignment Worker controls this by sending a ...
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
Spread::Message - provide messaging using the Spread toolkit
The Spread package provides a simple wrapper around the spread toolkit. We try to provide a much higher level wrapper. By providing: - Simple methods to send serialised Perl structures between programs - Callback registration - Extensible callbacks f...
MARKPF/Spread-Message-0.21 - 26 Apr 2006 21:38:02 UTC
Spread::Messaging - A Perl extension to the Spread Group Communications toolkit
To receive messages from a Spread network, your application could be as simple as this: use Spread::Messaging; sub handle_group { my $spread = shift; printf("Message: %s\n", $spread->message); } main: { my $spread; $spread = Spread::Messaging->new();...
KESTEB/Spread-Messaging-0.03 - 18 Sep 2008 17:44:14 UTC
Spread::Messaging::Content - A Perl extension for the Spread Group Communications toolkit
Your application could be as simple as this. use Spread::Messaging::Content; $spread = Spread::Messaging::Content->new(); $spread->join_group("test1"); for (;;) { if ($spread->poll()) { $spread->recv(); do_something(); } sleep(1); } sub do_something ...
KESTEB/Spread-Messaging-0.03 - 18 Sep 2008 17:44:14 UTC
Spread::Messaging::Transport - A Perl extension to the Spread Group Communications toolkit
Your application could be as simple as this, to receive messages from a Spread network. use Spread::Messaging::Transport; $spread = Spread::Messaging::Transport->new(); $spread->join_group("test"); for (;;) { if ($spread->poll()) { my ($service_type,...
KESTEB/Spread-Messaging-0.03 - 18 Sep 2008 17:44:14 UTC