Spread::Queue::FIFO - basic FIFO queue River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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 River stage zero No dependents

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

9 results (0.028 seconds)