diff --git a/amqp_relay.ml b/amqp_relay.ml
index 3869714..db3c536 100644
--- a/amqp_relay.ml
+++ b/amqp_relay.ml
@@ -396,7 +396,7 @@ let handshake_and_tune conn =
 
 let amqp_mainloop conn n =
   lwt () = Node.bind_ignore (conn.name, n) in
-  (try
+  (try_lwt
      lwt () = handshake_and_tune conn in
      while_lwt not conn.connection_closed do
        lwt (channel, m) = next_method conn in