Mojo::RabbitMQ::Client::Consumer3pm

  use Mojo::RabbitMQ::Client::Consumer;
  my $consumer = Mojo::RabbitMQ::Consumer->new(
    url      => 'amqp://guest:[email protected]: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;