diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-11 07:51:35 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-11 07:51:35 +0000 |
| commit | 58a3c2de2a4e27090c626d464e0485d7b91c3b18 (patch) | |
| tree | 2d32ca1040b2745fe19b1d4e52932f8d52594718 /src | |
| parent | 64a54d7f3daa0b3dfd6854bdce0d8c91e9d42851 (diff) | |
| download | rabbitmq-server-git-58a3c2de2a4e27090c626d464e0485d7b91c3b18.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 998dd50c8e..0b8ae74e98 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -698,12 +698,11 @@ handle_cast({client_dying, CRef}, handle_cast({client_delete, CRef}, State = #msstate { client_refs = ClientRefs, dying_clients = DyingClients }) -> - State1 = clear_client_callback(CRef, State), - noreply(remove_message( - CRef, CRef, - State1 #msstate { - client_refs = sets:del_element(CRef, ClientRefs), - dying_clients = sets:del_element(CRef, DyingClients) })); + State1 = clear_client_callback( + CRef, State #msstate { + client_refs = sets:del_element(CRef, ClientRefs), + dying_clients = sets:del_element(CRef, DyingClients) }), + noreply(remove_message(CRef, CRef, State1)); handle_cast({write, CRef, Guid}, State = #msstate { sum_valid_data = SumValid, |