diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:43:14 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:43:14 +0100 |
| commit | 8fddb286e59038dcfa4bb7a76e533676c6bd731f (patch) | |
| tree | 6ea426eb1cee4639a1c03536a36e4dae24bdadae | |
| parent | 4cbebceb0e5efd6591cd2f8fe07e6cacb31fcc6a (diff) | |
| download | rabbitmq-server-git-8fddb286e59038dcfa4bb7a76e533676c6bd731f.tar.gz | |
minor refactor
| -rw-r--r-- | src/rabbit_variable_queue.erl | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c75a2b11bd..7d92e04dba 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -569,14 +569,13 @@ requeue(AckTags, State) -> ack(fun (#msg_status { msg = Msg }, State1) -> {_SeqId, State2} = publish(Msg, true, false, State1), State2; - ({IsPersistent, Guid}, State1 = #vqstate { - msg_store_clients = MSCState }) -> + ({IsPersistent, Guid}, State1) -> + #vqstate { msg_store_clients = MSCState } = State1, {{ok, Msg = #basic_message{}}, MSCState1} = read_from_msg_store(MSCState, IsPersistent, Guid), - {_SeqId, State2} = publish(Msg, true, true, - State1 #vqstate { - msg_store_clients = MSCState1 }), - State2 + State2 = State1 #vqstate { msg_store_clients = MSCState1 }, + {_SeqId, State3} = publish(Msg, true, true, State2), + State3 end, AckTags, State). len(#vqstate { len = Len }) -> |