NAME

       Mojo::RabbitMQ::Client::Consumer - simple Mojo::RabbitMQ::Client based consumer

SYNOPSIS

         use Mojo::RabbitMQ::Client::Consumer;
         my $consumer = Mojo::RabbitMQ::Consumer->new(
           url      => 'amqp://guest:guest@127.0.0.1:5672/?exchange=mojo&queue=mojo',
           defaults => {
             qos      => {prefetch_count => 1},
             queue    => {durable        => 1},
             consumer => {no_ack         => 0},
           }
         );

         $consumer->catch(sub { die "Some error caught in Consumer" } );
         $consumer->on('success' => sub { say "Consumer ready" });
         $consumer->on(
           'message' => sub {
             my ($consumer, $message) = @_;

             $consumer->channel->ack($message)->deliver;
           }
         );
         $consumer->consume_p->wait;

         Mojo::IOLoop->start unless Mojo::IOLoop->is_running;

DESCRIPTION

EVENTS

       Mojo::RabbitMQ::Client::Consumer inherits all events from Mojo::EventEmitter and can emit
       the following new ones.

ATTRIBUTES

       Mojo::RabbitMQ::Client::Consumer has following attributes.

METHODS

       Mojo::RabbitMQ::Client::Consumer inherits all methods from Mojo::EventEmitter and
       implements the following new ones.

SEE ALSO

       Mojo::RabbitMQ::Client

COPYRIGHT AND LICENSE

       Copyright (C) 2015-2017, Sebastian Podjasek and others

       This program is free software, you can redistribute it and/or modify it under the terms of
       the Artistic License version 2.0.