---
name: "Mojo::RabbitMQ::Client::Consumer"
section: "3pm"
platform: "linux"
package: "libmojo-rabbitmq-client-perl"
version: "0.3.1-3"
release: "Debian 13 (Trixie)"
platforms: ["linux"]
url: "https://new.carta.tech/Mojo::RabbitMQ::Client::Consumer"
---

# Mojo::RabbitMQ::Client::Consumer(3pm)

simple Mojo::RabbitMQ::Client based consumer

## 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.