Skip to content

Commit

Permalink
Fix channel in test cases related to capabilities
Browse files Browse the repository at this point in the history
  • Loading branch information
@MarcialRosales
MarcialRosales committed Oct 24, 2024
1 parent 99ebbfc commit 8b7e856
Showing 1 changed file with 14 additions and 13 deletions.
27 changes: 14 additions & 13 deletions deps/amqp10_client/test/system_SUITE.erl
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ all() ->
{group, rabbitmq},
{group, rabbitmq_strict},
{group, activemq},
{group, ibmmq},
% {group, ibmmq},
{group, activemq_no_anon},
{group, mock}
].
Expand Down Expand Up @@ -967,25 +967,26 @@ set_receiver_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1},
BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}}
]}
]}
end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = true,
AttachStep = fun({0 = Ch, #'v1_0.attach'{role = true,
name = Name,
source = #'v1_0.source'{
capabilities = {symbol, <<"capability-1">>}}}, <<>>}) ->
capabilities = {symbol, <<"capability-1">>}}
}, <<>>}) ->
{Ch, [#'v1_0.attach'{name = Name,
handle = {uint, 99},
initial_delivery_count = {uint, 1},
role = false}
]}
end,

LinkCreditStep = fun({1 = Ch, #'v1_0.flow'{}, <<>>}) ->
LinkCreditStep = fun({0 = Ch, #'v1_0.flow'{}, <<>>}) ->
{Ch, {multi, [[#'v1_0.transfer'{handle = {uint, 99},
delivery_id = {uint, 12},
more = true},
Expand Down Expand Up @@ -1039,14 +1040,14 @@ set_sender_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1},
BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}}
]}
end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = false,
AttachStep = fun({0 = Ch, #'v1_0.attach'{role = false,
name = Name,
source = #'v1_0.source'{

Expand Down Expand Up @@ -1091,14 +1092,14 @@ set_sender_sync_capabilities(Config) ->
OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
{Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
end,
BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, 1},
BeginStep = fun({0 = Ch, #'v1_0.begin'{}, _Pay}) ->
{Ch, [#'v1_0.begin'{remote_channel = {ushort, Ch},
next_outgoing_id = {uint, 1},
incoming_window = {uint, 1000},
outgoing_window = {uint, 1000}}
]}
end,
AttachStep = fun({1 = Ch, #'v1_0.attach'{role = false,
AttachStep = fun({0 = Ch, #'v1_0.attach'{role = false,
name = Name,
source = #'v1_0.source'{

Expand Down

0 comments on commit 8b7e856

Please sign in to comment.