diff options
| author | Daniil Fedotov <dfedotov@pivotal.io> | 2017-09-27 10:22:16 +0100 |
|---|---|---|
| committer | Daniil Fedotov <dfedotov@pivotal.io> | 2017-10-02 14:34:47 +0100 |
| commit | 79a00a6f74383543f4ade05b2210bc93ce7d7ecd (patch) | |
| tree | eec376174e21f90e0412dd45d8d8fb29c6a3ede9 /test | |
| parent | bf531fd017cbec756ee979299723adce76828c96 (diff) | |
| download | rabbitmq-server-git-79a00a6f74383543f4ade05b2210bc93ce7d7ecd.tar.gz | |
Rename overflow values to use dashes instead of underscores
Diffstat (limited to 'test')
| -rw-r--r-- | test/priority_queue_SUITE.erl | 2 | ||||
| -rw-r--r-- | test/simple_ha_SUITE.erl | 2 | ||||
| -rw-r--r-- | test/unit_inbroker_parallel_SUITE.erl | 8 |
3 files changed, 6 insertions, 6 deletions
diff --git a/test/priority_queue_SUITE.erl b/test/priority_queue_SUITE.erl index eb781ffedf..a1ae66dbbb 100644 --- a/test/priority_queue_SUITE.erl +++ b/test/priority_queue_SUITE.erl @@ -311,7 +311,7 @@ reject(Config) -> {Conn, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0), Q = <<"reject-queue">>, declare(Ch, Q, [{<<"x-max-length">>, long, 4}, - {<<"x-overflow">>, longstr, <<"reject_publish">>} + {<<"x-overflow">>, longstr, <<"reject-publish">>} | arguments(3)]), publish(Ch, Q, [1, 2, 3, 1, 2, 3, 1, 2, 3]), %% First 4 messages are published, all others are discarded. diff --git a/test/simple_ha_SUITE.erl b/test/simple_ha_SUITE.erl index 297b53b713..f3af62d43a 100644 --- a/test/simple_ha_SUITE.erl +++ b/test/simple_ha_SUITE.erl @@ -230,7 +230,7 @@ rejecets_survive(Config, DeathFun) -> auto_delete = false, durable = true, arguments = [{<<"x-max-length">>, long, 1}, - {<<"x-overflow">>, longstr, <<"reject_publish">>}]}), + {<<"x-overflow">>, longstr, <<"reject-publish">>}]}), Payload = <<"there can be only one">>, amqp_channel:call(Node1Channel, #'basic.publish'{routing_key = Queue}, diff --git a/test/unit_inbroker_parallel_SUITE.erl b/test/unit_inbroker_parallel_SUITE.erl index 951cf6f213..d9ea349f1b 100644 --- a/test/unit_inbroker_parallel_SUITE.erl +++ b/test/unit_inbroker_parallel_SUITE.erl @@ -1050,7 +1050,7 @@ max_length_drop_head(Config) -> MaxLengthArgs = [{<<"x-max-length">>, long, 1}], MaxLengthBytesArgs = [{<<"x-max-length-bytes">>, long, 100}], - OverflowArgs = [{<<"x-overflow">>, longstr, <<"drop_head">>}], + OverflowArgs = [{<<"x-overflow">>, longstr, <<"drop-head">>}], amqp_channel:call(Ch, #'queue.delete'{queue = QName}), amqp_channel:call(Ch, #'queue.delete'{queue = QNameDefault}), amqp_channel:call(Ch, #'queue.delete'{queue = QNameBytes}), @@ -1076,7 +1076,7 @@ max_length_reject_confirm(Config) -> QNameBytes = <<"max_length_bytes_reject_queue">>, MaxLengthArgs = [{<<"x-max-length">>, long, 1}], MaxLengthBytesArgs = [{<<"x-max-length-bytes">>, long, 100}], - OverflowArgs = [{<<"x-overflow">>, longstr, <<"reject_publish">>}], + OverflowArgs = [{<<"x-overflow">>, longstr, <<"reject-publish">>}], amqp_channel:call(Ch, #'queue.delete'{queue = QName}), amqp_channel:call(Ch, #'queue.delete'{queue = QNameBytes}), #'queue.declare_ok'{} = amqp_channel:call(Ch, #'queue.declare'{queue = QName, arguments = MaxLengthArgs ++ OverflowArgs}), @@ -1099,12 +1099,12 @@ max_length_drop_publish(Config) -> QNameBytes = <<"max_length_bytes_drop_publish_queue">>, MaxLengthArgs = [{<<"x-max-length">>, long, 1}], MaxLengthBytesArgs = [{<<"x-max-length-bytes">>, long, 100}], - OverflowArgs = [{<<"x-overflow">>, longstr, <<"reject_publish">>}], + OverflowArgs = [{<<"x-overflow">>, longstr, <<"reject-publish">>}], amqp_channel:call(Ch, #'queue.delete'{queue = QName}), amqp_channel:call(Ch, #'queue.delete'{queue = QNameBytes}), #'queue.declare_ok'{} = amqp_channel:call(Ch, #'queue.declare'{queue = QName, arguments = MaxLengthArgs ++ OverflowArgs}), #'queue.declare_ok'{} = amqp_channel:call(Ch, #'queue.declare'{queue = QNameBytes, arguments = MaxLengthBytesArgs ++ OverflowArgs}), - %% If confirms are not enable, publishes will still be dropped in reject_publish mode. + %% If confirms are not enable, publishes will still be dropped in reject-publish mode. check_max_length_drops_publish(Config, QName, Ch, <<"1">>, <<"2">>, <<"3">>), %% 80 bytes payload |