diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 6895700cc2..c5f18a9462 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -897,18 +897,17 @@ should_force_index_to_disk(State = msg_store_callback(PersistentGuids, IsTransientPubs, Pubs, AckTags, Fun) -> Self = self(), - Fun = fun () -> rabbit_amqqueue:maybe_run_queue_via_backing_queue( - Self, fun (StateN) -> tx_commit_post_msg_store( - IsTransientPubs, Pubs, - AckTags, Fun, StateN) - end) - end, + F = fun () -> rabbit_amqqueue:maybe_run_queue_via_backing_queue( + Self, fun (StateN) -> tx_commit_post_msg_store( + IsTransientPubs, Pubs, + AckTags, Fun, StateN) + end) + end, fun () -> spawn(fun () -> ok = rabbit_misc:with_exit_handler( fun () -> rabbit_msg_store:remove( ?PERSISTENT_MSG_STORE, PersistentGuids) - end, - Fun) + end, F) end) end. |