diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-07 14:21:50 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-07 14:21:50 +0000 |
| commit | 3f4fed9733cbd87c339ea8b01b3682a3cdedd8bf (patch) | |
| tree | 73acf5ee6a86ac6feefc63fbd5cb769a7c591389 | |
| parent | 089ee7eb5d70ab867e892dab4312b36eb2c1e6db (diff) | |
| parent | 5f6d22c26a1720532b3e0d1a43da6466e69d87e9 (diff) | |
| download | rabbitmq-server-git-3f4fed9733cbd87c339ea8b01b3682a3cdedd8bf.tar.gz | |
Merge bug25945 again
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 94cfa61980..7fe12b9da7 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -704,7 +704,9 @@ remove_consumers(ChPid, Queue, QName) -> channel_consumers(ChPid, Queue) -> priority_queue:fold( fun ({CP, #consumer{tag = CTag}}, _, Acc) when CP =:= ChPid -> - [CTag | Acc] + [CTag | Acc]; + (_, _, Acc) -> + Acc end, [], Queue). possibly_unblock(State, ChPid, Update) -> |