Link the AMQP channel to the process listening, so that it can correct server problems.

diff --git a/amqp/amqp_bot_listener.erl b/amqp/amqp_bot_listener.erl
index 3fde833..0b54c34 100644 (file)
--- 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,