Use internal_send_command, since we're sending to a 'raw' socketbug23531

1 files changed, 3 insertions, 2 deletions

diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl
index 71115a73..28876838 100644
--- a/src/rabbit_reader.erl
+++ b/src/rabbit_reader.erl
@@ -590,8 +590,9 @@ handle_frame(Type, Channel, Payload,
                             %% We're already closing this channel, so
                             %% there's no cleanup to do (notify
                             %% queues, etc.)
-                            ok = rabbit_writer:send_command(State#v1.sock,
-                                                            #'channel.close_ok'{});
+                            ok = rabbit_writer:internal_send_command(
+                                   State#v1.sock, Channel, #'channel.close_ok'{},
+                                   Protocol);
                         _ -> ok
                     end,
                     State;