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 | 28310e48682f989b211bd587d2dc45d0e3516f3a (patch) | |
| tree | 401af982dff76ae4f8c492a3e5c5ab78c6f54040 | |
| parent | 615d2ce187a69735772f98af7d3d225569873286 (diff) | |
| download | rabbitmq-server-bug22525.tar.gz | |
maintain consistency of process dict channel entriesbug22525
(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 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}) -> |