diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-16 11:27:45 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-16 11:27:45 +0100 |
| commit | 42fac66afc783aecba5c6828aa82a0330f498067 (patch) | |
| tree | 0d6555d0488fbe5b954f1836d11db85eac56ff62 | |
| parent | 6fd72ad3a1e7e2dcef5adb68913c3b96bf84937b (diff) | |
| download | rabbitmq-server-git-42fac66afc783aecba5c6828aa82a0330f498067.tar.gz | |
bug fix.
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 831aa0446b..446042e0f7 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -398,7 +398,8 @@ purge1(Count, State = #vqstate { q3 = Q3, index_state = IndexState }) -> {Q3Count, IndexState1} = remove_queue_entries(Q3, IndexState), purge1(Count + Q3Count, maybe_load_next_segment( - State #vqstate { index_state = IndexState1 })) + State #vqstate { index_state = IndexState1, + q3 = queue:new() })) end. remove_queue_entries(Q, IndexState) -> |