summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_net.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_net.erl b/src/rabbit_net.erl
index 8c704b821b..a8b030b825 100644
--- a/src/rabbit_net.erl
+++ b/src/rabbit_net.erl
@@ -91,9 +91,11 @@ peername(Sock) when is_port(Sock) ->
port_command(Sock, Data) when is_record(Sock, ssl_socket) ->
case ssl:send(Sock#ssl_socket.ssl, Data) of
ok ->
+ self() ! {inet_reply, Sock, ok},
true;
{error, Reason} ->
- throw(Reason)
+ self() ! {inet_reply, Sock, {error, Reason}},
+ erlang:error(Reason)
end;
port_command(Sock, Data) when is_port(Sock) ->