Skip to content

Commit 2cd21ee

Browse files
Open the channel after max length limit is configured
1 parent 0c0ff72 commit 2cd21ee

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

test/unit_inbroker_parallel_SUITE.erl

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1320,16 +1320,18 @@ assert_channel_fail_max_size(Ch, Monitor, ExpectedException) ->
13201320

13211321
max_message_size(Config) ->
13221322
Binary128M = gen_binary_mb(128),
1323-
{_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0),
1323+
13241324
%% Default message size is 128MB
13251325
Size128Mb = 1024 * 1024 * 128,
1326+
Size128Mb = byte_size(Binary128M),
1327+
13261328
Size128Mb = rabbit_ct_broker_helpers:rpc(Config, 0,
13271329
application, get_env, [rabbit, max_message_size, undefined]),
1330+
{_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0),
13281331

1329-
Size128Mb = byte_size(Binary128M),
13301332
%% Binary is whithin the max size limit
13311333
amqp_channel:call(Ch, #'basic.publish'{routing_key = <<"nope">>}, #amqp_msg{payload = Binary128M}),
1332-
%% Channel process is alive
1334+
%% The channel process is alive
13331335
assert_channel_alive(Ch),
13341336

13351337
Monitor = monitor(process, Ch),

0 commit comments

Comments
 (0)