summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-02-20 19:59:45 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-02-20 19:59:45 +0000
commite0644af6536f224cbf9a9eac7bb158e1f767f23b (patch)
tree30b62ead8f7942f5085f14f8cf83e22652e316fd
parentcba68ce1a820cd6f57dc86482049714734d309cd (diff)
parent6bde32b8f6af20212b815d62e5aac051af14d62f (diff)
downloadrabbitmq-server-e0644af6536f224cbf9a9eac7bb158e1f767f23b.tar.gz
merge default into bug23749
-rw-r--r--src/rabbit_amqqueue_process.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index c0e74129..830ad35b 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -775,8 +775,8 @@ drop_expired_msgs(Now, State = #q{backing_queue_state = BQS,
fun () -> {Next, BQS1} = BQ:dropwhile(ExpirePred, BQS),
{Next, State#q{backing_queue_state = BQS1}} end),
ensure_ttl_timer(case Props of
- undefined -> undefined;
- #message_properties{expiry = Exp} -> Exp
+ undefined -> undefined;
+ #message_properties{expiry = Exp} -> Exp
end, State1).
with_dlx(undefined, _With, Without) -> Without();