diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2020-11-16 15:29:58 -0800 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2020-11-16 15:29:58 -0800 |
| commit | ea2da358e92f404172dc88ddff689e5cece2a252 (patch) | |
| tree | 02deb9a2f0e07d8fa69d3b243018a11c40b134c8 | |
| parent | d0d901f095e4d20e3560fb13feb1398ec236a84a (diff) | |
| download | rabbitmq-server-git-rabbitmq-amqp1.0-gh-104-monorepo.tar.gz | |
Test stream queues with AMQP 1.0rabbitmq-amqp1.0-gh-104-monorepo
Original PR https://github.com/rabbitmq/rabbitmq-amqp1.0/pull/104
cc @kjnilsson
cc @dcorbacho
| -rw-r--r-- | deps/rabbitmq_amqp1_0/test/system_SUITE.erl | 3 | ||||
| -rwxr-xr-x | deps/rabbitmq_amqp1_0/test/system_SUITE_data/fsharp-tests/Program.fs | 1 |
2 files changed, 4 insertions, 0 deletions
diff --git a/deps/rabbitmq_amqp1_0/test/system_SUITE.erl b/deps/rabbitmq_amqp1_0/test/system_SUITE.erl index b5c92c26ad..5e1b48c4f4 100644 --- a/deps/rabbitmq_amqp1_0/test/system_SUITE.erl +++ b/deps/rabbitmq_amqp1_0/test/system_SUITE.erl @@ -172,6 +172,9 @@ routing(Config) -> durable = false}), amqp_channel:call(Ch, #'queue.declare'{queue = <<"durable_q">>, durable = true}), + amqp_channel:call(Ch, #'queue.declare'{queue = <<"stream_q">>, + durable = true, + arguments = [{<<"x-queue-type">>, longstr, <<"stream">>}]}), amqp_channel:call(Ch, #'queue.declare'{queue = <<"autodel_q">>, auto_delete = true}), run(Config, [ diff --git a/deps/rabbitmq_amqp1_0/test/system_SUITE_data/fsharp-tests/Program.fs b/deps/rabbitmq_amqp1_0/test/system_SUITE_data/fsharp-tests/Program.fs index 19aa1009dd..33a9539c0c 100755 --- a/deps/rabbitmq_amqp1_0/test/system_SUITE_data/fsharp-tests/Program.fs +++ b/deps/rabbitmq_amqp1_0/test/system_SUITE_data/fsharp-tests/Program.fs @@ -313,6 +313,7 @@ module Test = * from the common_test suite. *) "/amq/queue/transient_q", "/amq/queue/transient_q", "", true "/amq/queue/durable_q", "/amq/queue/durable_q", "", true + "/amq/queue/stream_q", "/amq/queue/stream_q", "", true "/amq/queue/autodel_q", "/amq/queue/autodel_q", "", true] do let rnd = Random() |