NAME

Spread::Queue::Sender - submit messages to Spread::Queue message queues

SYNOPSIS

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" });

DESCRIPTION

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 serialized Perl hashes. Spread::Queue does not enforce structure on message contents.

METHODS

new

my $sender = new Spread::Queue::Sender("myqueue");

rpc

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).