diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-02-24 15:43:11 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-02-24 15:43:11 +0000 |
| commit | 84f12e7eb0397c761d88282a39a7a4be17b1d5b6 (patch) | |
| tree | 036760e5a5895ab8b1bf0af2054f5d057bcd5222 /src | |
| parent | 93ca3857e92e73f0e1fbfe8e83fd6f76f22b3425 (diff) | |
| download | rabbitmq-server-git-84f12e7eb0397c761d88282a39a7a4be17b1d5b6.tar.gz | |
add missing head
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 225fc2ddaa..a63bda7045 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -637,6 +637,8 @@ ack(AckTags, State) -> persistent_count = PCount1, ack_out_counter = AckOutCount + length(AckTags) })}. +process_messages(_AckTags, undefined, State) -> + State; process_messages(AckTags, MsgFun, State = #vqstate{pending_ack = PA}) -> lists:foldl( fun(SeqId, State1) -> |