Skip to content

Instantly share code, notes, and snippets.

open_connection_link(Params) ->
process_flag(trap_exit, true),
{ok, Conn} = amqp_connection:start(network, Params),
link(Conn),
receive
{'EXIT', Conn, Reason} ->
exit(Reason);
{'EXIT', _Pid, Reason} ->
ok = amqp_connection:close(Conn),
exit(Reason)