summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorEssien Ita Essien <essiene@gmail.com>2008-12-16 22:30:38 +0100
committerEssien Ita Essien <essiene@gmail.com>2008-12-16 22:30:38 +0100
commit980d52bdbe0a1bf655e1b2b466b846e0d80b0331 (patch)
tree2fa62642ae880b88a034b935cd6ec93d3e1f0974 /src
parentcd5c1e58d4426d4554a711e0a1f8d31261a2a606 (diff)
downloadrabbitmq-server-git-980d52bdbe0a1bf655e1b2b466b846e0d80b0331.tar.gz
Use rabbit_net layer in rabbit_writer.erl
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_writer.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_writer.erl b/src/rabbit_writer.erl
index 9cf9f8aef9..5ca294b762 100644
--- a/src/rabbit_writer.erl
+++ b/src/rabbit_writer.erl
@@ -139,7 +139,7 @@ assemble_frames(Channel, MethodRecord, Content, FrameMax) ->
tcp_send(Sock, Data) ->
rabbit_misc:throw_on_error(inet_error,
- fun () -> gen_tcp:send(Sock, Data) end).
+ fun () -> rabbit_net:send(Sock, Data) end).
internal_send_command(Sock, Channel, MethodRecord) ->
ok = tcp_send(Sock, assemble_frames(Channel, MethodRecord)).
@@ -176,6 +176,6 @@ internal_send_command_async(Sock, Channel, MethodRecord, Content, FrameMax) ->
ok.
port_cmd(Sock, Data) ->
- try erlang:port_command(Sock, Data)
+ try rabbit_net:port_command(Sock, Data)
catch error:Error -> exit({writer, send_failed, Error})
end.