diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-12-03 13:02:30 +0000 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-12-03 13:02:30 +0000 |
| commit | cf229b48130743509783e65927c6ca77928c6dc8 (patch) | |
| tree | dc8e6319e5d5d9f39c0e03cb51e16989c2f7bbbd | |
| parent | 01f29e902ebd825bbc74cfcdca17c0574daf859b (diff) | |
| download | rabbitmq-server-cf229b48130743509783e65927c6ca77928c6dc8.tar.gz | |
Whitespace
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index a6b3829b..2ffa2a1a 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -743,7 +743,7 @@ drop_expired_messages(State = #q{dlx = DLX, end, State#q{backing_queue_state = BQS1}). accumulate_msgs(Msg, _IsDelivered, AckTag, Acc) -> [{Msg, AckTag} | Acc]. - + ensure_ttl_timer(undefined, State) -> State; ensure_ttl_timer(Expiry, State = #q{ttl_timer_ref = undefined}) -> |