Skip to content

Commit 7fed677

Browse files
author
Simon MacMullen
committed
Use server-named exclusive queues.
1 parent d3e9f10 commit 7fed677

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

test/src/com/rabbitmq/client/test/server/EffectVisibilityCrossNodeTest.java

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -60,19 +60,14 @@ public void closeConnection() throws IOException {
6060
protected void createResources() throws IOException {
6161
channel.exchangeDeclare(exchange, "fanout");
6262
for (int i = 0; i < queues.length ; i++) {
63-
queues[i] = "queue-" + System.nanoTime();
64-
secondaryChannel.queueDeclare(queues[i]);
63+
queues[i] = secondaryChannel.queueDeclare().getQueue();
6564
secondaryChannel.queueBind(queues[i], exchange, "");
66-
secondaryChannel.queuePurge(queues[i]);
6765
}
6866
}
6967

7068
@Override
7169
protected void releaseResources() throws IOException {
7270
channel.exchangeDelete(exchange);
73-
for (int i = 0; i < queues.length ; i++) {
74-
secondaryChannel.queueDelete(queues[i]);
75-
}
7671
}
7772

7873
private static final int QUEUES = 5;

0 commit comments

Comments
 (0)