AnyEvent::RabbitMQ - An asynchronous and multi channel Perl AMQP client.
use AnyEvent::RabbitMQ; my $cv = AnyEvent->condvar; my $ar = AnyEvent::RabbitMQ->new->load_xml_spec( '/path/to/amqp0-8.xml', )->connect( host => 'localhosti', port => 5672, user => 'guest', port => 'guest', vhost => '/', timeout => 1, on_success => sub { $ar->open_channel( on_success => sub { my $channel = shift; $channel->declare_exchange( exchange => 'test_exchange', on_success => sub { $cv->send('Declared exchange'); }, on_failure => $cv, ); }, on_failure => $cv, on_close => sub { my $method_frame = shift->method_frame; die $method_frame->reply_code, $method_frame->reply_text; } ); }, on_failure => $cv, on_read_failure => sub {die @_}, on_close => sub { my $method_frame = shift->method_frame; die $method_frame->reply_code, $method_frame->reply_text; }, ); print $cv->recv, "\n";
AnyEvent::RabbitMQ is an AMQP(Advanced Message Queuing Protocol) client library, that is intended to allow you to interact with AMQP-compliant message brokers/servers such as RabbitMQ in an asynchronous fashion.
You can use AnyEvent::RabbitMQ to -
* Declare and delete exchanges * Declare, delete, bind and unbind queues * Set QoS * Publish, consume, get, ack and recover messages * Select, commit and rollback transactions
AnyEvnet::RabbitMQ is known to work with RabbitMQ versions 1.7.2 and version 0-8 of the AMQP specification.
Masahito Ikuta <cooldaemon@gmail.com>
This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.
To install Net::RabbitFoot, copy and paste the appropriate command in to your terminal.
cpanm
cpanm Net::RabbitFoot
CPAN shell
perl -MCPAN -e shell install Net::RabbitFoot
For more information on module installation, please visit the detailed CPAN module installation guide.