diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-01-25 14:00:17 +0000 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-01-25 14:00:17 +0000 |
| commit | 5f55a91f1a5e7af2c05df56cc5834d77c7e902a8 (patch) | |
| tree | bdf4b36098b6f0bb3751ea01000954d73eda9c1a | |
| parent | 8d55bda7fa11fbfd0b12c3482f366f492b49c80f (diff) | |
| download | rabbitmq-server-git-5f55a91f1a5e7af2c05df56cc5834d77c7e902a8.tar.gz | |
'case' statement style
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 6625ce4561..9c8cc87570 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1283,8 +1283,9 @@ reject_tx(DeliveryTag, Multiple, Requeue, State1 = State#ch{unacked_message_q = Remaining}, {noreply, case TxStatus of - none -> reject(Requeue, Acked, State1#ch.limiter), - State1; + none -> + reject(Requeue, Acked, State1#ch.limiter), + State1; in_progress -> State1#ch{uncommitted_nacks = {Requeue, Acked} ++ State1#ch.uncommitted_nacks} |