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

Shovel dynamic_SUITE: cosmetics

This commit is contained in:
Michael Klishin 2023-06-29 17:44:32 +04:00
parent 9a6bf31e9a
commit 9a1104dba0
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
deps/rabbitmq_shovel/test/dynamic_SUITE.erl vendored
View File

@ -268,13 +268,13 @@ missing_dest_exchange(Config) ->
with_ch(Config,
fun (Ch) ->
amqp_channel:call(
Ch, #'queue.declare'{queue = <<"src">>, % E: record 'queue.declare' undefined
durable = true}),
Ch, #'queue.declare'{queue = <<"src">>,
durable = true}),
amqp_channel:call(
Ch, #'queue.declare'{queue = <<"dest">>, % E: record 'queue.declare' undefined
durable = true}),
Ch, #'queue.declare'{queue = <<"dest">>,
durable = true}),
amqp_channel:call(
Ch, #'queue.bind'{queue = <<"src">>, % E: record 'queue.bind' undefined
Ch, #'queue.bind'{queue = <<"src">>,
exchange = <<"amq.direct">>,
routing_key = <<"src-key">>}),
shovel_test_utils:set_param(Config,
@ -285,9 +285,9 @@ missing_dest_exchange(Config) ->
publish(Ch, <<"amq.direct">>, <<"src-key">>, <<"hello">>),
expect_empty(Ch, <<"src">>),
amqp_channel:call(
Ch, #'exchange.declare'{exchange = <<"dest-ex">>}), % E: record 'exchange.declare' undefined
Ch, #'exchange.declare'{exchange = <<"dest-ex">>}),
amqp_channel:call(
Ch, #'queue.bind'{queue = <<"dest">>, % E: record 'queue.bind' undefined
Ch, #'queue.bind'{queue = <<"dest">>,
exchange = <<"dest-ex">>,
routing_key = <<"dest-key">>}),
publish_expect(Ch, <<"amq.direct">>, <<"src-key">>, <<"dest">>, <<"hello!">>)