diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-23 15:03:08 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-23 15:03:08 +0000 |
| commit | 3509f72455ad8ad9486eb710d75b1e4f5e738f00 (patch) | |
| tree | 7824dfeb1542b2157a6e9f3d38b08914947772bf | |
| parent | a3114513fae53a8261a2d72f1fa0c54bded4ad28 (diff) | |
| download | rabbitmq-server-git-3509f72455ad8ad9486eb710d75b1e4f5e738f00.tar.gz | |
don't check the return of credit_flow:{peer_down,ack}
we don't do this anywhere else
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 606848ee58..61794fd09e 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -626,7 +626,7 @@ handle_ch_down(DownPid, State = #q{exclusive_consumer = Holder, senders = Senders}) -> Senders1 = case pmon:is_monitored(DownPid, Senders) of false -> Senders; - true -> ok = credit_flow:peer_down(DownPid), + true -> credit_flow:peer_down(DownPid), pmon:demonitor(DownPid, Senders) end, case lookup_ch(DownPid) of @@ -1247,7 +1247,7 @@ handle_cast({deliver, Delivery = #delivery{sender = Sender, State = #q{senders = Senders}) -> %% Asynchronous, non-"mandatory", non-"immediate" deliver mode. Senders1 = case Flow of - flow -> ok = credit_flow:ack(Sender), + flow -> credit_flow:ack(Sender), pmon:monitor(Sender, Senders); noflow -> ok end, |