diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-04-21 17:43:49 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-04-21 17:43:49 +0100 |
| commit | 5d1d5400b5c1027d91dba12cb758be648a915b47 (patch) | |
| tree | d8c9e5efe53a1165ef417063f7ab408d8aeaff8d /src | |
| parent | 617bf6e64470e7946e6a355b88e0d67c2054d539 (diff) | |
| download | rabbitmq-server-git-5d1d5400b5c1027d91dba12cb758be648a915b47.tar.gz | |
Cosmetics
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, []}; |