NAME

AMQP::Subscriber -- Listens for messages on a queue and does stuff with them.

SYNOPSIS

 use AMQP::Subscriber;
 my $subscriber = AMQP::Subscriber->new;
 $subscriber->server('amqp://foo:bar@localhost:5672/testing');
 $subscriber->exchange('test');
 $subscriber->type('topic');
 $subscriber->queue('testing');
 $subscriber->callback( sub {
        my ($self,$message) = @_;
        say $message;
 });
 $subscriber->attach;

DESCRIPTION

The AMQP::Subscriber wraps

METHODS

new( \%params ) (constructor)

Create a new instance of this class. Initialize the object with whatever is in \%params, which are not predefined.</p>

Returns: new instance of this class.

server($url)

Configures all of the connection settings based on an AMQP url. The format of which is:

 amqp://username:password@host:port/vhost

All of the elements of the url are required if you are not using the defaults. The default settings are:

 amqp://guest:guest@localhost:5672/

attach()

TODO

BUGS

If you find them out

COPYRIGHT

Same as Perl.

AUTHORS

Dave Goehrig <dave@dloh.org>