diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 17:42:03 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-13 17:42:03 +0100 |
| commit | a71f11f702fa9f2bcc236d36f53d2641231f07e6 (patch) | |
| tree | 9308b72ed4efe3dd95a5cd9cc4f813a811f22467 /src/rabbit_router.erl | |
| parent | 02eac84cd7d15916f5bc9e23ee39845625cf9db8 (diff) | |
| download | rabbitmq-server-a71f11f702fa9f2bcc236d36f53d2641231f07e6.tar.gz | |
refactoring
What's done:
- PubAck after transient messages
- PubAck after basic.returns
- PubAck after message delivered to a consumer (disregarding
consumer acks)
- PubAck after message got
- out of order ack'ing
- multiple ack'ing
Whant's not done:
- PubAck de-duplication
- PubAck after message hits disk
Diffstat (limited to 'src/rabbit_router.erl')
| -rw-r--r-- | src/rabbit_router.erl | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/src/rabbit_router.erl b/src/rabbit_router.erl index 14d93497..0f8611d0 100644 --- a/src/rabbit_router.erl +++ b/src/rabbit_router.erl @@ -66,7 +66,6 @@ deliver(QPids, Delivery = #delivery{mandatory = false, delegate:invoke_no_result( QPids, fun (Pid) -> rabbit_amqqueue:deliver(Pid, Delivery) end), case {QPids, Msg#basic_message.msg_seq_no} of - {[], undefined} -> ok; {[], MsgSeqNo} -> rabbit_channel:confirm(Msg#basic_message.origin, MsgSeqNo); _ -> ok end, |