diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-02-27 14:52:07 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-02-27 14:52:07 +0000 |
| commit | d10dd65d2fd20ea7feb61d4328962993e99a9084 (patch) | |
| tree | d4ecb831e3fc003f63c20ddae0f81d00e6769750 /src | |
| parent | f59845ff7fc9faf76e3b1f213d15cd0d36933ea3 (diff) | |
| download | rabbitmq-server-git-d10dd65d2fd20ea7feb61d4328962993e99a9084.tar.gz | |
Cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 1 |
2 files changed, 1 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index d2ebce2a2c..951a5008bf 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1288,8 +1288,7 @@ handle_cast({ack, AckTags, ChPid}, State) -> ChPid, AckTags, State, fun (State1 = #q{backing_queue = BQ, backing_queue_state = BQS}) -> - {_Guids, BQS1} = - BQ:ack(AckTags, BQS), + {_Guids, BQS1} = BQ:ack(AckTags, BQS), State1#q{backing_queue_state = BQS1} end)); diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index a63bda7045..9f187d927d 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -615,7 +615,6 @@ fetch(AckRequired, State) -> ack([], State) -> {[], State}; - ack(AckTags, State) -> {{IndexOnDiskSeqIds, MsgIdsByStore, AllMsgIds}, State1 = #vqstate { index_state = IndexState, |