diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-01-02 00:49:36 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-01-02 00:49:36 +0300 |
| commit | 2cd21ee0e87cfd646b753cfbb8de32b50773bd68 (patch) | |
| tree | 2f849a1c78618cdb9f25ed4a555688a5855620a6 | |
| parent | 0c0ff722884966de654a5768d610aae87899e561 (diff) | |
| download | rabbitmq-server-git-2cd21ee0e87cfd646b753cfbb8de32b50773bd68.tar.gz | |
Open the channel after max length limit is configured
| -rw-r--r-- | test/unit_inbroker_parallel_SUITE.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/test/unit_inbroker_parallel_SUITE.erl b/test/unit_inbroker_parallel_SUITE.erl index 94fcc3a177..126f3b9083 100644 --- a/test/unit_inbroker_parallel_SUITE.erl +++ b/test/unit_inbroker_parallel_SUITE.erl @@ -1320,16 +1320,18 @@ assert_channel_fail_max_size(Ch, Monitor, ExpectedException) -> max_message_size(Config) -> Binary128M = gen_binary_mb(128), - {_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0), + %% Default message size is 128MB Size128Mb = 1024 * 1024 * 128, + Size128Mb = byte_size(Binary128M), + Size128Mb = rabbit_ct_broker_helpers:rpc(Config, 0, application, get_env, [rabbit, max_message_size, undefined]), + {_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0), - Size128Mb = byte_size(Binary128M), %% Binary is whithin the max size limit amqp_channel:call(Ch, #'basic.publish'{routing_key = <<"nope">>}, #amqp_msg{payload = Binary128M}), - %% Channel process is alive + %% The channel process is alive assert_channel_alive(Ch), Monitor = monitor(process, Ch), |