Skip to content

Commit 730ffa5

Browse files
Be more lenient when deleting dying client entries
If no entry was deleted, that's suspicious but it's certainly more important to keep queue process functional.
1 parent 736a61d commit 730ffa5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/rabbit_msg_store.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -705,7 +705,7 @@ client_update_flying(Diff, MsgId, #client_msstate { flying_ets = FlyingEts,
705705
clear_client(CRef, State = #msstate { cref_to_msg_ids = CTM,
706706
dying_clients = DyingClients,
707707
dying_client_index = DyingIndex }) ->
708-
true = ets:delete(DyingIndex, CRef),
708+
ets:delete(DyingIndex, CRef),
709709
State #msstate { cref_to_msg_ids = dict:erase(CRef, CTM),
710710
dying_clients = sets:del_element(CRef, DyingClients) }.
711711

0 commit comments

Comments
 (0)