diff options
| -rw-r--r-- | src/rabbit_reader.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index e33c6de2..48f65985 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -623,6 +623,7 @@ create_channel(Channel, Protocol, User, VHost, Capabilities, Collector}), MRef = erlang:monitor(process, ChPid), put({ch_pid, ChPid}, {Channel, MRef}), + put({channel, Channel}, {ChPid, AState}), {ok, {ChPid, AState}, State#v1{channel_count = ChannelCount + 1}}. channel_cleanup(ChPid, State = #v1{channel_count = ChannelCount}) -> |