diff options
| -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 5841bf6287..a631990bff 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -860,7 +860,7 @@ cleanup_after_confirm(State = #q{blocked_ops = Ops, State1 = State#q{blocked_ops = []}, case lists:any(fun({Rsn, _}) -> Rsn =:= delete end, Ops) of true -> {stop, normal, State1}; - false -> noreply(State) + false -> noreply(State1) end; false -> noreply(State) end. |