diff options
| author | Essien Ita Essien <essiene@gmail.com> | 2008-12-16 22:30:38 +0100 |
|---|---|---|
| committer | Essien Ita Essien <essiene@gmail.com> | 2008-12-16 22:30:38 +0100 |
| commit | 980d52bdbe0a1bf655e1b2b466b846e0d80b0331 (patch) | |
| tree | 2fa62642ae880b88a034b935cd6ec93d3e1f0974 /src | |
| parent | cd5c1e58d4426d4554a711e0a1f8d31261a2a606 (diff) | |
| download | rabbitmq-server-git-980d52bdbe0a1bf655e1b2b466b846e0d80b0331.tar.gz | |
Use rabbit_net layer in rabbit_writer.erl
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_writer.erl | 4 |
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. |
