diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-23 18:51:38 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-23 18:51:38 +0000 |
| commit | fc853e94a462b75dad5d90456c1ba03b71865c9a (patch) | |
| tree | 05f2bf826908218fabb0ff9a862a71fef2db64cc | |
| parent | 45df15468ec057c51931ca0dca5c102d02da5c46 (diff) | |
| download | rabbitmq-server-git-fc853e94a462b75dad5d90456c1ba03b71865c9a.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 41fc173b2b..613c11daa1 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -333,12 +333,10 @@ ensure_expiry_timer(State = #q{expires = undefined}) -> State; ensure_expiry_timer(State = #q{expires = Expires}) -> case is_unused(State) of - true -> - NewState = stop_expiry_timer(State), - TRef = erlang:send_after(Expires, self(), maybe_expire), - NewState#q{expiry_timer_ref = TRef}; - false -> - State + true -> NewState = stop_expiry_timer(State), + TRef = erlang:send_after(Expires, self(), maybe_expire), + NewState#q{expiry_timer_ref = TRef}; + false -> State end. ensure_stats_timer(State) -> |
