Spread::Queue::Sender - submit messages to Spread::Queue message queues
use Spread::Queue::Sender; my $sender = new Spread::Queue::Sender(QUEUE => "myqueue"); $sender->submit({ name => "value" }); my $response = $sender->receive;
or
my $response = $sender->rpc({ name => "value" });
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, by default using Data::Denter.
Spread::Queue does not enforce structure on message contents.
my $serlzr = new Data::Serialization(serializer => "YAML"); my $sender = new Spread::Queue::Sender(QUEUE => "myqueue", SERIALIZER => $serlzr);
Establish Spread session for transmitting messages to a queue of workers. The SERIALIZER parameter is optional, by default using Data::Denter.
$sender->submit($data);
$data should be a hashref, which will be serialized and published as a Spread message.
my $response = $sender->receive($timeout);
Wait for an incoming message on the sender's private Spread address. This is just a pass-through to Spread::Session::receive.
my $response = $sender->rpc($data [, $timeout]);
RPC-style invocation of a remote operation. Waits $timeout seconds for a response (returns undef if no response arrives).
$sender->status;
Transmit an administrative status request to the queue manager.
1 POD Error
The following errors were encountered while parsing the POD:
'=item' outside of any '=over'
=over without closing =back
To install Spread::Queue::FIFO, copy and paste the appropriate command in to your terminal.
cpanm
cpanm Spread::Queue::FIFO
CPAN shell
perl -MCPAN -e shell install Spread::Queue::FIFO
For more information on module installation, please visit the detailed CPAN module installation guide.