There is a small change required in this article on Introducing The Erlang AMQP Client.
In this article, code for subscribing to an queue is
#'basic.consume_ok'{consumer_tag = ConsumerTag}
= amqp_channel:call(Channel, BasicConsume, self()),
This throws exception
Channel 1 is shutting down due to: {{badmatch,false},
[{rabbit_writer,assemble_frames,4},
{rabbit_writer,
internal_send_command_async,5},
{rabbit_writer,handle_message,2},
{rabbit_writer,mainloop,1}]}
Change it to amqp_channel:subscribe(Channel, BasicConsume, self())
NOTE: Download rabbitmq erlang client from here. The version from this page does not work.
No comments:
Post a Comment