Skip to content

Commit 33e6461

Browse files
Still issues using capabilities with ibm mq
1 parent 9efd864 commit 33e6461

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

deps/amqp10_client/test/system_SUITE.erl

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -350,7 +350,7 @@ roundtrip(OpenConf) ->
350350
roundtrip(OpenConf, Body) ->
351351
roundtrip(OpenConf, Body, [], []).
352352

353-
roundtrip(OpenConf, Body, Args, DoNotAssertMessageProperties) ->
353+
roundtrip(OpenConf, Body, Args, _DoNotAssertMessageProperties) ->
354354
{ok, Connection} = amqp10_client:open_connection(OpenConf),
355355
{ok, Session} = amqp10_client:begin_session(Connection),
356356
Destination = proplists:get_value(destination, Args, <<"test1">>),
@@ -389,8 +389,7 @@ roundtrip(OpenConf, Body, Args, DoNotAssertMessageProperties) ->
389389

390390
ReceiverAttachArgs = #{name => <<"banana-receiver">>,
391391
role => {receiver, #{address => Destination,
392-
durable => unsettled_state,
393-
capabilities => ReceiverCapabilities}, self()},
392+
durable => unsettled_state}, self()},
394393
snd_settle_mode => settled,
395394
rcv_settle_mode => first,
396395
filter => #{},
@@ -466,7 +465,12 @@ basic_roundtrip_with_sender_and_receiver_capabilities(Config) ->
466465
application:start(sasl),
467466
Hostname = ?config(rmq_hostname, Config),
468467
Port = rabbit_ct_broker_helpers:get_node_config(Config, 0, tcp_port_amqp),
469-
OpenConf = #{address => Hostname, port => Port, sasl => ?config(sasl, Config)},
468+
%% an address list
469+
OpenConf = #{addresses => [Hostname],
470+
port => Port,
471+
notify => self(),
472+
container_id => <<"open_close_connection_container">>,
473+
sasl => ?config(sasl, Config)},
470474
roundtrip(OpenConf, <<"banana">>, [
471475
{destination, <<"DEV.QUEUE.3">>},
472476
{sender_capabilities, <<"queue">>},

0 commit comments

Comments
 (0)