diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2011-06-20 12:59:33 +0100 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2011-06-20 12:59:33 +0100 |
| commit | 0bc93d9ea3d7b8f268f1fcdeb98013a29db31ea2 (patch) | |
| tree | b17521ff0b50342f7a81382966a460347dd076c4 | |
| parent | c4281184b8f440aa7ef82d7fa9875c764fc84890 (diff) | |
| download | rabbitmq-server-git-0bc93d9ea3d7b8f268f1fcdeb98013a29db31ea2.tar.gz | |
Rename MsgState -> AckEntry
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index cefa06562e..cf82c639cc 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -688,9 +688,9 @@ internal_fetch(AckRequired, MsgStatus = #msg_status { ack(AckTags, Fun, State) -> {MsgIds, State1} = ack(fun msg_store_remove/3, - fun (MsgState, State0) -> + fun (AckEntry, State0) -> {_, State2} = Fun(read_msg_callback(), - {MsgState, State0}), + {AckEntry, State0}), State2 end, AckTags, State), |