summaryrefslogtreecommitdiff
path: root/src/rabbit_net.erl
diff options
context:
space:
mode:
authorEssien Ita Essien <essiene@gmail.com>2008-12-28 23:54:04 +0100
committerEssien Ita Essien <essiene@gmail.com>2008-12-28 23:54:04 +0100
commitf41b858d1c692606533e1fb4c6b5e13f6f2a46a2 (patch)
treea97ff8ba583f18c7765aab24f8686e866c53f5d4 /src/rabbit_net.erl
parentd8e50e32f969acae7aa9ea8304301c6bdbd26d2a (diff)
downloadrabbitmq-server-f41b858d1c692606533e1fb4c6b5e13f6f2a46a2.tar.gz
Make rabbit_net:port_command mimick erlang:port_command more closely
Diffstat (limited to 'src/rabbit_net.erl')
-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 8c704b82..a8b030b8 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) ->