diff options
| -rw-r--r-- | src/rabbit_msg_store.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index c95cff1e27..167ab41c8c 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -618,6 +618,9 @@ client_update_flying(Diff, MsgId, #client_msstate { flying_ets = FlyingEts, true -> ok; false -> try ets:update_counter(FlyingEts, Key, {2, Diff}) catch error:badarg -> + %% this is guaranteed to succeed since the + %% server only removes and updates flying_ets + %% entries; it never inserts them true = ets:insert_new(FlyingEts, {Key, Diff}) end, ok |