diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-10 18:33:05 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-10-10 18:33:05 +0100 |
| commit | e6dc10ed8514fc2f5e1812adb109492b3881e767 (patch) | |
| tree | 58e6d04734ffcc37043dc09fecad3a82bdbb4bc2 /src/rabbit_msg_store.erl | |
| parent | 0eca27507a30da56461c85fa60ec02eb8851c9e6 (diff) | |
| download | rabbitmq-server-e6dc10ed8514fc2f5e1812adb109492b3881e767.tar.gz | |
cosmetic
Diffstat (limited to 'src/rabbit_msg_store.erl')
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 1c2603fa..2ea6d616 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -572,8 +572,8 @@ client_read3(#msg_location { msg_id = MsgId, file = File }, Defer, end end. -update_flying(Diff, MsgId, #client_msstate { flying_ets = FlyingEts, - client_ref = CRef }) -> +update_flying(Diff, MsgId, #client_msstate { flying_ets = FlyingEts, + client_ref = CRef }) -> Key = {MsgId, CRef}, case ets:insert_new(FlyingEts, {Key, Diff}) of true -> ok; |