diff options
| -rw-r--r-- | src/rabbit_reader.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index bcf588f09a..687e638a69 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -634,12 +634,11 @@ create_channel(Channel, State) -> channel_cleanup(ChPid, State = #v1{channel_count = ChannelCount}) -> case get({ch_pid, ChPid}) of undefined -> {undefined, State}; - {Channel, MRef} -> State1 = State#v1{channel_count = (ChannelCount - 1)}, - credit_flow:peer_down(ChPid), + {Channel, MRef} -> credit_flow:peer_down(ChPid), erase({channel, Channel}), erase({ch_pid, ChPid}), erlang:demonitor(MRef, [flush]), - {Channel, State1} + {Channel, State#v1{channel_count = ChannelCount - 1}} end. all_channels() -> [ChPid || {{ch_pid, ChPid}, _ChannelMRef} <- get()]. |