diff options
| -rw-r--r-- | src/rabbit_msg_store.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 68f346ca70..ed3adf6538 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -705,7 +705,7 @@ client_update_flying(Diff, MsgId, #client_msstate { flying_ets = FlyingEts, clear_client(CRef, State = #msstate { cref_to_msg_ids = CTM, dying_clients = DyingClients, dying_client_index = DyingIndex }) -> - true = ets:delete(DyingIndex, CRef), + ets:delete(DyingIndex, CRef), State #msstate { cref_to_msg_ids = dict:erase(CRef, CTM), dying_clients = sets:del_element(CRef, DyingClients) }. |