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()->connect(
    host       => 'localhost',
    port       => 5672,
    user       => 'guest',
    pass       => 'guest',
    vhost      => '/',
    timeout    => 1,
    tls        => 0, # Or 1 if you'd like SSL
    tls_ctx    => $anyevent_tls # or a hash of AnyEvent::TLS options.
    tune       => { heartbeat => 30, channel_max => $whatever, frame_max = $whatever },
    nodelay    => 1, # Reduces latency by disabling Nagle's algorithm
    on_success => sub {
        my $ar = shift;
        $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_return  => sub {
        my $frame = shift;
        die "Unable to deliver ", Dumper($frame);
    },
    on_close   => sub {
        my $why = shift;
        if (ref($why)) {
            my $method_frame = $why->method_frame;
            die $method_frame->reply_code, ": ", $method_frame->reply_text;
        }
        else {
            die $why;
        }
    },
);
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 and confirm mode
* Publish, consume, get, ack, recover and reject messages
* Select, commit and rollback transactions
            
          

Most of these actions can be done through AnyEvent::RabbitMQ::Channel. Please see the documentation there for more details.

AnyEvent::RabbitMQ is known to work with RabbitMQ versions 2.5.1 and versions 0-8 and 0-9-1 of the AMQP specification.

This client is the non-blocking version, for a blocking version with a similar API, see Net::RabbitFoot.

AUTHOR

Masahito Ikuta <cooldaemon@gmail.com>

MAINTAINER

Currently maintained by <bobtfish@bobtfish.net> due to the original author being missing in action.

COPYRIGHT

Copyright (c) 2010, the above named author(s).

SEE ALSO

LICENSE

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