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 | 281542f5c285b6c005e396eee2f3e4493b7e2ec7 (patch) | |
| tree | 0fef4fe72875331f0cd1aa874abfaf19edeca891 | |
| parent | cbbe81b575def63e9edd47dd1a66e034fc1367b6 (diff) | |
| download | rabbitmq-server-git-281542f5c285b6c005e396eee2f3e4493b7e2ec7.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 f2fd0388af..9921417e51 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) -> |