root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Fix channel in test cases related to capabilities

This commit is contained in:
Marcial Rosales 2024-10-24 10:23:58 +02:00
parent eeebd4a80b
commit 0a4d8a8a50
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
deps/amqp10_client/test/system_SUITE.erl vendored
View File

@ -24,7 +24,7 @@ all() ->
{group, rabbitmq}, {group, rabbitmq},
{group, rabbitmq_strict}, {group, rabbitmq_strict},
{group, activemq}, {group, activemq},
{group, ibmmq}, % {group, ibmmq},
{group, activemq_no_anon}, {group, activemq_no_anon},
{group, mock} {group, mock}
]. ].
@ -967,17 +967,18 @@ set_receiver_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) -> OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]} {Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end, end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) -> BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1}, {Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1}, next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000}, incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}} outgoing_window = {uint, 1000}}
]} ]}
end, end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = true, AttachStep = fun({0 = Ch, #'v1_0.attach'{role = true,
name = Name, name = Name,
source = #'v1_0.source'{ source = #'v1_0.source'{
capabilities = {symbol, <<"capability-1">>}}}, <<>>}) -> capabilities = {symbol, <<"capability-1">>}}
}, <<>>}) ->
{Ch, [#'v1_0.attach'{name = Name, {Ch, [#'v1_0.attach'{name = Name,
handle = {uint, 99}, handle = {uint, 99},
initial_delivery_count = {uint, 1}, initial_delivery_count = {uint, 1},
@ -985,7 +986,7 @@ set_receiver_capabilities(Config) ->
]} ]}
end, end,
LinkCreditStep = fun({1 = Ch, #'v1_0.flow'{}, <<>>}) -> LinkCreditStep = fun({0 = Ch, #'v1_0.flow'{}, <<>>}) ->
{Ch, {multi, [[#'v1_0.transfer'{handle = {uint, 99}, {Ch, {multi, [[#'v1_0.transfer'{handle = {uint, 99},
delivery_id = {uint, 12}, delivery_id = {uint, 12},
more = true}, more = true},
@ -1039,14 +1040,14 @@ set_sender_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) -> OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]} {Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end, end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) -> BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1}, {Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1}, next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000}, incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}} outgoing_window = {uint, 1000}}
]} ]}
end, end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = false, AttachStep = fun({0 = Ch, #'v1_0.attach'{role = false,
name = Name, name = Name,
source = #'v1_0.source'{ source = #'v1_0.source'{
@ -1091,14 +1092,14 @@ set_sender_sync_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) -> OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]} {Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end, end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) -> BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1}, {Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1}, next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000}, incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}} outgoing_window = {uint, 1000}}
]} ]}
end, end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = false, AttachStep = fun({0 = Ch, #'v1_0.attach'{role = false,
name = Name, name = Name,
source = #'v1_0.source'{ source = #'v1_0.source'{