diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-12-05 13:56:15 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-12-05 13:56:15 +0000 |
| commit | cb16018fc2376699a2e5b6a19417ad7157c0f310 (patch) | |
| tree | 0fef4fe72875331f0cd1aa874abfaf19edeca891 | |
| parent | 26eebb2bb949cb17cdffc8477224fcb3b7aa7f6d (diff) | |
| download | rabbitmq-server-cb16018fc2376699a2e5b6a19417ad7157c0f310.tar.gz | |
Reinstate this.
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index f2fd0388..9921417e 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -652,7 +652,7 @@ fetch(AckRequired, State) -> %% at this point, so read it in. {Msg, State2} = read_msg(MsgStatus, State1), {AckTag, State3} = remove(AckRequired, MsgStatus, State2), - {{Msg, MsgStatus#msg_status.is_delivered, AckTag}, State3} + {{Msg, MsgStatus#msg_status.is_delivered, AckTag}, a(State3)} end. drop(AckRequired, State) -> |