diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-10-24 10:15:43 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-10-24 10:15:43 +0100 |
| commit | 84529c4c6495482e66a17fdbc0e92afa2078ee5d (patch) | |
| tree | c9db32f74b646c077d411a35867907f8e874a89a | |
| parent | c5b13a91e29f03630a5fd8016f1d42ea46a11865 (diff) | |
| download | rabbitmq-server-bug24514.tar.gz | |
Update VQ soak tests for new requeue APIbug24514
| -rw-r--r-- | src/rabbit_backing_queue_qc.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl index 095202dd..6e6b2917 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -128,8 +128,7 @@ qc_ack(#state{bqstate = BQ, acks = Acks}) -> {call, ?BQMOD, ack, [rand_choice(proplists:get_keys(Acks)), BQ]}. qc_requeue(#state{bqstate = BQ, acks = Acks}) -> - {call, ?BQMOD, requeue, - [rand_choice(proplists:get_keys(Acks)), fun(MsgOpts) -> MsgOpts end, BQ]}. + {call, ?BQMOD, requeue, [rand_choice(proplists:get_keys(Acks)), BQ]}. qc_set_ram_duration_target(#state{bqstate = BQ}) -> {call, ?BQMOD, set_ram_duration_target, @@ -245,7 +244,7 @@ next_state(S, Res, {call, ?BQMOD, ack, [AcksArg, _BQ]}) -> S#state{bqstate = BQ1, acks = lists:foldl(fun proplists:delete/2, AcksState, AcksArg)}; -next_state(S, Res, {call, ?BQMOD, requeue, [AcksArg, _F, _V]}) -> +next_state(S, Res, {call, ?BQMOD, requeue, [AcksArg, _V]}) -> #state{messages = Messages, acks = AcksState} = S, BQ1 = {call, erlang, element, [2, Res]}, Messages1 = lists:foldl(fun (AckTag, Msgs) -> |