diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-06-27 00:10:56 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-06-27 00:10:56 +0300 |
| commit | 730ffa5f906f6e1aca34a333d5d6c7350ed3e2dd (patch) | |
| tree | 997bf484737a2e8b5a10b5827ad1719ab4639bee /src | |
| parent | 736a61d9a73fcd9ead3b5358cb9e9d4f17728805 (diff) | |
| download | rabbitmq-server-git-730ffa5f906f6e1aca34a333d5d6c7350ed3e2dd.tar.gz | |
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.
Diffstat (limited to 'src')
| -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) }. |