oops

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.