diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 5 | ||||
| -rw-r--r-- | src/rabbit_router.erl | 6 |
2 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 791a55fea7..1dd92403b0 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -324,9 +324,8 @@ basic_consume(#amqqueue{pid = QPid}, NoAck, ReaderPid, ChPid, LimiterPid, infinity). basic_cancel(#amqqueue{pid = QPid}, ChPid, ConsumerTag, OkMsg) -> - ok = delegate:gs2_call(QPid, - {basic_cancel, ChPid, ConsumerTag, OkMsg}, - infinity). + ok = delegate:gs2_call(QPid, {basic_cancel, ChPid, ConsumerTag, OkMsg}, + infinity). notify_sent(QPid, ChPid) -> delegate:gs2_pcast(QPid, 7, {notify_sent, ChPid}). diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 5fd5715bea..6a886eacdc 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -110,9 +110,9 @@ lookup_qpids(Queues) -> %%-------------------------------------------------------------------- -fold_deliveries({ok, true, Pid}, {_, Handled}) -> {true, [Pid | Handled]}; -fold_deliveries({ok, false, _}, {_, Handled}) -> {true, Handled}; -fold_deliveries({error, _, _}, {Routed, Handled}) -> {Routed, Handled}. +fold_deliveries({ok, true, Pid},{_, Handled}) -> {true, [Pid|Handled]}; +fold_deliveries({ok, false, _ },{_, Handled}) -> {true, Handled}; +fold_deliveries({error, _ , _ },{Routed, Handled}) -> {Routed, Handled}. %% check_delivery(Mandatory, Immediate, {WasRouted, QPids}) check_delivery(true, _ , {false, []}) -> {unroutable, []}; |