diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-05-25 18:12:57 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-05-25 18:12:57 +0100 |
| commit | ff084083c8424564615b541a6911ef5f3c45939d (patch) | |
| tree | 3ba91b78dc92ffac8793180a77c9a4d3f946d4e3 | |
| parent | ccc1a6463ee7d24ab1388d64af13a854ab9f8a02 (diff) | |
| download | rabbitmq-server-git-ff084083c8424564615b541a6911ef5f3c45939d.tar.gz | |
Whoops
| -rw-r--r-- | src/rabbit_variable_queue.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 88c2719a36..30f16fd260 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -369,7 +369,10 @@ terminate(State) -> persistent_count = PCount, index_state = IndexState, msg_store_clients = {{MSCStateP, PRef}, {MSCStateT, TRef}} } = remove_pending_ack(true, tx_commit_index(State)), - rabbit_msg_store:client_terminate(MSCStateP), + case MSCStateP of + undefined -> ok; + _ -> rabbit_msg_store:client_terminate(MSCStateP) + end, rabbit_msg_store:client_terminate(MSCStateT), Terms = [{persistent_ref, PRef}, {transient_ref, TRef}, |