From 66e2ccda9ff74e245b0f9526483064264593ec6f Mon Sep 17 00:00:00 2001 From: Matt Mullins Date: Sun, 28 Aug 2011 15:37:14 -0500 Subject: [PATCH] Link the AMQP channel to the process listening, so that it can correct server problems. --- amqp/amqp_bot_listener.erl | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/amqp/amqp_bot_listener.erl b/amqp/amqp_bot_listener.erl index 3fde833..0b54c34 100644 --- a/amqp/amqp_bot_listener.erl +++ b/amqp/amqp_bot_listener.erl @@ -17,8 +17,12 @@ %% %% Note this calls basic.consume with no_ack=true, so messages are %% automatically removed from the queue when they occur +%% +%% This links the Channel to the current process so that it can handle, for +%% instance, the AMQP server dying. listen_for_events(RoutingKeyString) -> {ok, Channel} = amqp_bot_connection:open_channel(), + link(Channel), RoutingKeyBinary = list_to_binary(RoutingKeyString), Pid = self(), #'exchange.declare_ok'{} = amqp_channel:call(Channel, -- 2.11.0