diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-11 07:43:31 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-01-11 07:43:31 +0000 |
| commit | 858ac89d42f8dfe8c973ab4116acc2b038300b2d (patch) | |
| tree | 13464348e9b7c8b117d4ec9bf8688c913abffdf2 | |
| parent | 3fdbf7a7a77de951aeedc6a482c2f61bf23f969f (diff) | |
| download | rabbitmq-server-858ac89d42f8dfe8c973ab4116acc2b038300b2d.tar.gz | |
fix
| -rw-r--r-- | src/rabbit_msg_store.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 1831bda8..998dd50c 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -698,12 +698,12 @@ 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, - clear_client_callback( - State #msstate { - client_refs = sets:del_element(CRef, ClientRefs), - dying_clients = sets:del_element(CRef, DyingClients) }))); + State1 #msstate { + client_refs = sets:del_element(CRef, ClientRefs), + dying_clients = sets:del_element(CRef, DyingClients) })); handle_cast({write, CRef, Guid}, State = #msstate { sum_valid_data = SumValid, |