diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 4d02657fd4..7fdd8ee63c 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -552,6 +552,9 @@ handle_frame(Type, Channel, Payload, Channel, ChPid, FramingState), put({channel, Channel}, {ChPid, NewAState}), case AnalyzedFrame of + {method, #'channel.close_ok'{}, _} -> + erase({channel, Channel}), + State; {method, MethodName, _} -> case (State#v1.connection_state =:= blocking andalso |