diff options
| -rw-r--r-- | src/rabbit_persister.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_persister.erl b/src/rabbit_persister.erl index 8aa5ad8d32..8f04123e39 100644 --- a/src/rabbit_persister.erl +++ b/src/rabbit_persister.erl @@ -236,8 +236,7 @@ complete(From, Item, State = #pstate{deadline = ExistingDeadline, %% "tied" is met. log_work(CreateWorkUnit, MessageList, State = #pstate{ - snapshot = Snapshot = #psnapshot{ - messages = Messages}}) -> + snapshot = Snapshot = #psnapshot{messages = Messages}}) -> Unit = CreateWorkUnit( rabbit_misc:map_in_order( fun(M = {publish, Message, QK = {_QName, PKey}}) -> |