diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-21 16:07:34 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-21 16:07:34 +0000 |
| commit | d8b237c4b6952c676dfb55084e8acff01dd139ad (patch) | |
| tree | 2596a48952291cac3a22487fdfdb2ba8c2f460be /test/src | |
| parent | 043dd23be06db4015aaf32ffb282cf162d92c8ca (diff) | |
| parent | 8a605773ce360d3f29edbf639bebbd204d8c7b7a (diff) | |
| download | rabbitmq-server-git-d8b237c4b6952c676dfb55084e8acff01dd139ad.tar.gz | |
Merge bug 26527
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 870dfdd99a..f19c361e94 100644 --- a/test/src/rabbit_tests.erl +++ b/test/src/rabbit_tests.erl @@ -2448,7 +2448,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) -> @@ -2514,7 +2514,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)). |