NAME

AnyEvent::RabbitMQ - An asynchronous and multi channel Perl AMQP client.

SYNOPSIS

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

DESCRIPTION

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.

AUTHOR

Masahito Ikuta <cooldaemon@gmail.com>

SEE ALSO

LICENSE

This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.