diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index b6578b7efb..08ce0ed6fd 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -150,7 +150,8 @@ code_change(_OldVsn, State, _Extra) -> %%---------------------------------------------------------------------------- init_queue_state(State) -> - init_expires(init_ttl(State)). + lists:foldr(fun(F, S) -> F(S) end, State, + [fun init_expires/1, fun init_ttl/1]). init_expires(State = #q{q = #amqqueue{arguments = Arguments}}) -> case rabbit_misc:table_lookup(Arguments, <<"x-expires">>) of |