File Coverage

blib/lib/Message/Passing/AMQP/ConnectionManager.pm

Criterion	Covered	Total	%
statement	21	22	95.4
branch			n/a
condition			n/a
subroutine	7	8	87.5
pod			n/a
total	28	30	93.3

package Message::Passing::AMQP::ConnectionManager;
use Moo;
use Types::Standard qw( Bool Str Int );
use Scalar::Util qw/ weaken /;
use AnyEvent;
use AnyEvent::RabbitMQ;
use Carp qw/ croak /;
use namespace::autoclean;

with qw/
    Message::Passing::Role::ConnectionManager
    Message::Passing::Role::HasHostnameAndPort
    Message::Passing::Role::HasUsernameAndPassword
/;

sub _default_port { 5672 }

has vhost => (
    is => 'ro',
    isa => Str,
    required => 1,
);

has tls => (
    is => 'ro',
    isa => Bool,
    default => sub { 0 },
);

has verbose => (
    is => 'ro',
    isa => Bool,
    default => sub { 0 },
);

my $has_loaded;
sub _build_connection {
    my $self = shift;
    weaken($self);
    my $client = AnyEvent::RabbitMQ->new(
        verbose => $self->verbose,
    );
    $client->load_xml_spec unless $has_loaded++;
    $client->connect(
        host       => $self->hostname,
        port       => $self->port,
        user       => $self->username,
        pass       => $self->password,
        vhost      => $self->vhost,
        tls        => $self->tls,
        timeout    => $self->timeout,
        on_success => sub {
            $self->_set_connected(1);
        },
        on_failure => sub {
            my ($error) = @_;
            warn("CONNECT ERROR $error");
            $self->_set_connected(0);
        },
        on_close => sub {
            warn("CLOSED");
            $self->_set_connected(0);
        },
    );
    return $client;
}

1;

=head1 NAME

Message::Passing::AMQP::ConnectionManager - Implements the Message::Passing::Role::HasAConnection interface.

=head1 ATTRIBUTES

=head2 vhost

Passed to L<AnyEvent::RabbitMQ>->new->connect.

=head2 timeout

Passed to L<AnyEvent::RabbitMQ>->new->connect.

=head2 tls

Passed to L<AnyEvent::RabbitMQ>->new->connect.

=head2 verbose

Passed to L<AnyEvent::RabbitMQ>->new.

=head1 AUTHOR, COPYRIGHT AND LICENSE

See L<Message::Passing::AMQP>.

=cut