[rabbitmq-discuss] rabbitmq erlang amqp_client question.

Mon Jun 2 10:48:55 BST 2014

On 30/05/2014 5:34AM, ale wrote:
> Hi,
>
> I’m implementing a basic consumer in erlang using the
> amqp_gen_consumer behavior from the official amqp_client.

Is there a reason you're implementing amqp_gen_consumer yourself? 
Normally you would use amqp_selective_consumer or amqp_direct_consumer 
rather than implementing your own.

If you do want your own consumer implementation, you need to configure 
it by opening the channel with amqp_connection:open_channel/2 not /1:

{ok, Channel} = amqp_connection:open_channel(
                     Connection, {my_consumer_module, ConsumerArgs})

> All that is working fine but hen I publish messages to the queue I
> would expect to receive messages via the [handle_deliver] callback
> but instead I’m receiving messages trough [handle_info].

That's the default amqp_direct_consumer behaviour you're seeing.

Cheers, Simon

-- 
Simon MacMullen
RabbitMQ, Pivotal