diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-05 11:32:24 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-05 11:32:24 +0100 |
| commit | 03cbbed9abe8ae44df191212ae837148ed46e16f (patch) | |
| tree | c38afc1ae943441a78eba2ff756c49d2014d923b | |
| parent | d2f2d3323a2aa1d0d9fb249702b25c85e00c6dbf (diff) | |
| download | rabbitmq-server-03cbbed9abe8ae44df191212ae837148ed46e16f.tar.gz | |
refactor: shrink
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index e33b8339..1a3edc8b 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -542,18 +542,16 @@ deliver_or_enqueue(Delivery = #delivery{message = Message, msg_seq_no = MsgSeqNo, sender = SenderPid}, State) -> Confirm = should_confirm_message(Delivery, State), - {Delivered, State1} = attempt_delivery(Delivery, Confirm, State), - case Delivered of - true -> + case attempt_delivery(Delivery, Confirm, State) of + {true, State1} -> maybe_record_confirm_message(Confirm, State1); %% optimisation - false when State1#q.ttl == 0 andalso State1#q.dlx == undefined -> - case Confirm of - never -> ok; - _ -> rabbit_misc:confirm_to_sender(SenderPid, [MsgSeqNo]) - end, + {false, State1 = #q{ttl = 0, dlx = undefined}} when Confirm == never -> + discard_delivery(Delivery, State1); + {false, State1 = #q{ttl = 0, dlx = undefined}} -> + rabbit_misc:confirm_to_sender(SenderPid, [MsgSeqNo]), discard_delivery(Delivery, State1); - false -> + {false, State1} -> State2 = #q{backing_queue = BQ, backing_queue_state = BQS} = maybe_record_confirm_message(Confirm, State1), Props = message_properties(Confirm, State2), |