diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-12 14:37:20 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-12 14:37:20 +0000 |
| commit | 75a472ee850bbc95e50d60f1fed5a13512f8d1e5 (patch) | |
| tree | 3c279f4f4bfc3b3cbbaec185f842ef3d4de4b86e /test/src | |
| parent | 29c0ecd4db98c3a7b15742388acd591fddc7f95b (diff) | |
| download | rabbitmq-server-git-75a472ee850bbc95e50d60f1fed5a13512f8d1e5.tar.gz | |
Flow control for messages going from channel to slave via GM. Reshuffle the flow control flag into #delivery{} to try to cut down on the number of places it gets passed around. Still to come: DTRT on promotion.
Diffstat (limited to 'test/src')
| -rw-r--r-- | test/src/rabbit_tests.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/src/rabbit_tests.erl b/test/src/rabbit_tests.erl index dcbec8f606..eab25d5161 100644 --- a/test/src/rabbit_tests.erl +++ b/test/src/rabbit_tests.erl @@ -2444,7 +2444,7 @@ variable_queue_publish(IsPersistent, Start, Count, PropFun, PayloadFun, VQ) -> end}, PayloadFun(N)), PropFun(N, #message_properties{size = 10}), - false, self(), VQN) + false, self(), noflow, VQN) end, VQ, lists:seq(Start, Start + Count - 1))). variable_queue_fetch(Count, IsPersistent, IsDelivered, Len, VQ) -> @@ -2501,7 +2501,8 @@ publish_and_confirm(Q, Payload, Count) -> <<>>, #'P_basic'{delivery_mode = 2}, Payload), Delivery = #delivery{mandatory = false, sender = self(), - confirm = true, message = Msg, msg_seq_no = Seq}, + confirm = true, message = Msg, msg_seq_no = Seq, + flow = noflow}, _QPids = rabbit_amqqueue:deliver([Q], Delivery) end || Seq <- Seqs], wait_for_confirms(gb_sets:from_list(Seqs)). |