diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-11 14:46:35 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-11 14:46:35 +0100 |
| commit | 2cb4ef50dc89da1c1574ed027d1c323f428707b1 (patch) | |
| tree | 00e7cd08163fd3dbf6ee76aaa5a4690ce979b949 /src | |
| parent | 49965c60a8896416e5a508859c2f00c4f0aa6f43 (diff) | |
| download | rabbitmq-server-git-2cb4ef50dc89da1c1574ed027d1c323f428707b1.tar.gz | |
remove a remnant of 'immediate'
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 30df2b5ca3..9706efbfa8 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -543,16 +543,10 @@ attempt_delivery(#delivery{sender = SenderPid, message = Message}, Props, {{Message, Props#message_properties.delivered, AckTag}, true, State1#q{backing_queue_state = BQS3}} end, false, State#q{backing_queue_state = BQS1}); - {Duplicate, BQS1} -> - %% if the message has previously been seen by the BQ then - %% it must have been seen under the same circumstances as - %% now: i.e. if it is now a deliver_immediately then it - %% must have been before. - {case Duplicate of - published -> true; - discarded -> false - end, - State#q{backing_queue_state = BQS1}} + {published, BQS1} -> + {true, State#q{backing_queue_state = BQS1}}; + {discarded, BQS1} -> + {false, State#q{backing_queue_state = BQS1}} end. deliver_or_enqueue(Delivery = #delivery{message = Message, |
