Skip to content

Commit 0fb5082

Browse files
Resolve a conflict (#9549)
1 parent 2ce9d4c commit 0fb5082

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

deps/rabbit/app.bzl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1104,7 +1104,7 @@ def test_suite_beam_files(name = "test_suite_beam_files"):
11041104
outs = ["test/policy_SUITE.beam"],
11051105
app_name = "rabbit",
11061106
erlc_opts = "//:test_erlc_opts",
1107-
deps = ["//deps/amqp_client:erlang_app"],
1107+
deps = ["//deps/amqp_client:erlang_app", "//deps/rabbitmq_ct_helpers:erlang_app"],
11081108
)
11091109
erlang_bytecode(
11101110
name = "priority_queue_SUITE_beam_files",

deps/rabbit/test/policy_SUITE.erl

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,8 @@
99

1010
-include_lib("common_test/include/ct.hrl").
1111
-include_lib("amqp_client/include/amqp_client.hrl").
12-
12+
-include_lib("stdlib/include/assert.hrl").
13+
-include_lib("rabbitmq_ct_helpers/include/rabbit_assert.hrl").
1314

1415
-compile(export_all).
1516

@@ -218,8 +219,6 @@ target_count_policy(Config) ->
218219
rabbit_ct_client_helpers:close_connection(Conn),
219220
passed.
220221

221-
<<<<<<< HEAD
222-
=======
223222
queue_type_specific_policies(Config) ->
224223
[Server | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
225224
{Conn, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0),
@@ -381,15 +380,18 @@ effective_operator_policy_per_queue_type(Config, Name, Value, ClassicValue, Quor
381380
rabbit_ct_client_helpers:close_channel(Ch),
382381
rabbit_ct_client_helpers:close_connection(Conn),
383382
passed.
384-
>>>>>>> 24797c5a12 (Add Classic Queue version to operator policies)
385383

386384
%%----------------------------------------------------------------------------
387385

388-
389386
declare(Ch, Q) ->
390387
amqp_channel:call(Ch, #'queue.declare'{queue = Q,
391388
durable = true}).
392389

390+
declare(Ch, Q, Args) ->
391+
amqp_channel:call(Ch, #'queue.declare'{queue = Q,
392+
durable = true,
393+
arguments = Args}).
394+
393395
delete(Ch, Q) ->
394396
amqp_channel:call(Ch, #'queue.delete'{queue = Q}).
395397

0 commit comments

Comments
 (0)