diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-12 15:52:50 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-12 15:52:50 +0000 |
| commit | cdff3eca6098564c9100e0b156847bef283867bd (patch) | |
| tree | d4b57b956d1200219df189d270299948cfc70314 /src | |
| parent | 3d23167b9c793d76469af0eef52347f4262ebb39 (diff) | |
| download | rabbitmq-server-git-cdff3eca6098564c9100e0b156847bef283867bd.tar.gz | |
Avert eyesore.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 10b27e05df..fee633786b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -642,11 +642,9 @@ handle_ch_down(DownPid, State = #q{exclusive_consumer = Holder}) -> handle_ch_publisher_down(DownPid) -> case lookup_ch_publisher(DownPid) of - not_found -> - ok; - _ -> - erase_ch_record_publisher(DownPid), - rabbit_flow:sender_down(DownPid) + not_found -> ok; + _ -> erase_ch_record_publisher(DownPid), + rabbit_flow:sender_down(DownPid) end. check_exclusive_access({_ChPid, _ConsumerTag}, _ExclusiveConsume, _State) -> |