Search results for "distribution:Spread-Queue Spread-Queue"
Spread::Queue - One-of-many queued messaging delivery, using Spread
Message-queueing layer using Spread for message delivery. Queues are managed by a dedicated manager process (sqm). This agent coordinates task assignments for some number of workers who accept messages delivered to a queue (a Spread public group). Wo...
JMAY/Spread-Queue-0.4 - 25 Oct 2002 22:08:09 UTC
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