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 | 6747406f83dfa6ff8c461d529424356dc4e70fd9 (patch) | |
| tree | bdf4b36098b6f0bb3751ea01000954d73eda9c1a | |
| parent | 46e5a9fb699c37c662824e947c402d0e62a38947 (diff) | |
| download | rabbitmq-server-6747406f83dfa6ff8c461d529424356dc4e70fd9.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 6625ce45..9c8cc875 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} |