diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-15 16:29:48 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-15 16:29:48 +0100 |
| commit | 9ebad4995a7a3354cb43c9868cc61144b84d95dd (patch) | |
| tree | 52a0982363e8103b613856facab305b8c0022c29 /src | |
| parent | efc62091ec50587b7d18f1d6d80dca6702f95fd8 (diff) | |
| download | rabbitmq-server-git-9ebad4995a7a3354cb43c9868cc61144b84d95dd.tar.gz | |
refactor: handle all msg statuses uniformly
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 3bd787d316..6d7bc3041e 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -633,12 +633,7 @@ maybe_enqueue_message( MQ1 = queue:in(Delivery, MQ), SQ1 = dict:store(ChPid, {MQ1, PendingCh}, SQ), State1 #state { sender_queues = SQ1 }; - {ok, confirmed} -> - ok = rabbit_misc:confirm_to_sender(ChPid, [MsgSeqNo]), - SQ1 = remove_from_pending_ch(MsgId, ChPid, SQ), - State1 #state { msg_id_status = dict:erase(MsgId, MS), - sender_queues = SQ1 }; - {ok, Status} when Status =:= published orelse Status =:= discarded -> + {ok, Status} -> MS1 = case needs_confirming(Status, Delivery, State1) of never -> dict:erase(MsgId, MS); eventually -> MMS = {Status, ChPid, MsgSeqNo}, |