diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-12-14 16:47:14 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-12-14 16:47:14 +0000 |
| commit | 2ddc94916b10351843664d34490fe12938afb160 (patch) | |
| tree | 88492df6a07f5220cf3b1a846e268ab9ae3a9c8f /src | |
| parent | ac195255233defa27ca4319ecba2dee6e0278991 (diff) | |
| download | rabbitmq-server-git-2ddc94916b10351843664d34490fe12938afb160.tar.gz | |
Shortcut
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index bcbdb0ad53..90e58f25d7 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -568,9 +568,7 @@ attempt_delivery(Delivery = #delivery{sender = SenderPid, message = Message}, {false, State#q{backing_queue_state = BQS1}} end. -deliver_or_enqueue(Delivery = #delivery{message = Message, - msg_seq_no = MsgSeqNo, - sender = SenderPid}, +deliver_or_enqueue(Delivery = #delivery{message = Message}, Delivered, State) -> {Confirm, State1} = send_or_record_confirm(Delivery, State), Props = message_properties(Message, Confirm, State), @@ -606,18 +604,13 @@ publish_max(#delivery{message = Message, {false, _} -> BQ:publish(Message, Props, Delivered, SenderPid, BQS); {true, true} -> - case XName of - undefined -> - ok; - _ -> - case rabbit_exchange:lookup(XName) of - {ok, X} -> dead_letter_publish(Message, maxdepth, X, State); - {error, not_found} -> ok - end + case rabbit_exchange:lookup(XName) of + {ok, X} -> dead_letter_publish(Message, maxdepth, X, State); + {error, _} -> ok end, case Confirm of - true -> rabbit_misc:confirm_to_sender(SenderPid, [MsgSeqNo]); - _ -> ok + true -> rabbit_misc:confirm_to_sender(SenderPid, [MsgSeqNo]); + false -> ok end, BQS; {true, false} -> |
