diff options
| author | Tim Watson <tim@rabbitmq.com> | 2013-06-14 14:33:44 +0100 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2013-06-14 14:33:44 +0100 |
| commit | b390a52c7a576ff79b466ae7b2ffea8c95f306d4 (patch) | |
| tree | a2a472d952f0c0bdcf9962ab34f104655330b93e /src | |
| parent | 2e14763f5334c4ef0efb26e965420b1f0a3dc346 (diff) | |
| parent | 20370276a5dd52b3fba2d397420a5e716a86859f (diff) | |
| download | rabbitmq-server-git-b390a52c7a576ff79b466ae7b2ffea8c95f306d4.tar.gz | |
merge bug25600 into stable
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 1de14b5ce4..22692dcbfe 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1198,7 +1198,8 @@ handle_publishing_queue_down(QPid, Reason, State = #ch{unconfirmed = UC}) -> handle_consuming_queue_down(QPid, State = #ch{consumer_mapping = ConsumerMapping, - queue_consumers = QCons}) -> + queue_consumers = QCons, + queue_names = QNames}) -> ConsumerTags = case dict:find(QPid, QCons) of error -> gb_sets:new(); {ok, CTags} -> CTags @@ -1208,6 +1209,11 @@ handle_consuming_queue_down(QPid, ok = send(#'basic.cancel'{consumer_tag = CTag, nowait = true}, State), + rabbit_event:notify( + consumer_deleted, + [{consumer_tag, CTag}, + {channel, self()}, + {queue, dict:fetch(QPid, QNames)}]), dict:erase(CTag, CMap) end, ConsumerMapping, ConsumerTags), State#ch{consumer_mapping = ConsumerMapping1, |