diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 15:16:40 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-12 15:16:40 +0000 |
| commit | c6579be6fd71de1db80511e95a9ec80a0a721183 (patch) | |
| tree | 401af982dff76ae4f8c492a3e5c5ab78c6f54040 | |
| parent | ba27272b077f24c4ba3553fbe57ceb40b58d255b (diff) | |
| download | rabbitmq-server-git-c6579be6fd71de1db80511e95a9ec80a0a721183.tar.gz | |
maintain consistency of process dict channel entries
(just as we used to)
| -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 e33c6de2cb..48f65985c5 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}) -> |