summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorkjnilsson <knilsson@pivotal.io>2020-10-16 14:42:21 +0100
committerkjnilsson <knilsson@pivotal.io>2020-10-16 14:42:21 +0100
commitbfe9eebc635d7a1b13981bf66995279d7d4c48c0 (patch)
treead5d162e70f246fc6d18af1db46572cb0faf4591
parentedf1cdff9e3b49bbde2af25a2fd4aa8662f8be0c (diff)
downloadrabbitmq-server-git-bfe9eebc635d7a1b13981bf66995279d7d4c48c0.tar.gz
Use named queues for single_active_consumer test
-rw-r--r--test/single_active_consumer_SUITE.erl7
1 files changed, 5 insertions, 2 deletions
diff --git a/test/single_active_consumer_SUITE.erl b/test/single_active_consumer_SUITE.erl
index 63b56fa009..59f2b6e83d 100644
--- a/test/single_active_consumer_SUITE.erl
+++ b/test/single_active_consumer_SUITE.erl
@@ -83,7 +83,8 @@ init_per_group(quorum_queue, Config) ->
end_per_group(_, Config) ->
Config.
-init_per_testcase(Testcase, Config) ->
+init_per_testcase(Testcase, Config0) ->
+ Config = [{queue_name, atom_to_binary(Testcase, utf8)} | Config0],
rabbit_ct_helpers:testcase_started(Config, Testcase).
end_per_testcase(Testcase, Config) ->
rabbit_ct_helpers:testcase_finished(Config, Testcase).
@@ -290,7 +291,9 @@ connection_and_channel(Config) ->
{C, Ch}.
queue_declare(Channel, Config) ->
- Declare = ?config(single_active_consumer_queue_declare, Config),
+ QueueName = ?config(queue_name, Config),
+ Declare0 = ?config(single_active_consumer_queue_declare, Config),
+ Declare = Declare0#'queue.declare'{queue = QueueName},
#'queue.declare_ok'{queue = Q} = amqp_channel:call(Channel, Declare),
Q.