try -> try_lwt
This commit is contained in:
parent
513f0f7334
commit
aa87e25a95
|
@ -396,7 +396,7 @@ let handshake_and_tune conn =
|
||||||
|
|
||||||
let amqp_mainloop conn n =
|
let amqp_mainloop conn n =
|
||||||
lwt () = Node.bind_ignore (conn.name, n) in
|
lwt () = Node.bind_ignore (conn.name, n) in
|
||||||
(try
|
(try_lwt
|
||||||
lwt () = handshake_and_tune conn in
|
lwt () = handshake_and_tune conn in
|
||||||
while_lwt not conn.connection_closed do
|
while_lwt not conn.connection_closed do
|
||||||
lwt (channel, m) = next_method conn in
|
lwt (channel, m) = next_method conn in
|
||||||
|
|
Loading…
Reference in New Issue