Skip to content

Commit a26ae4b

Browse files
Be more proactive about cleaning up exchanges declared here
1 parent 88ef19e commit a26ae4b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

test/src/com/rabbitmq/client/test/functional/AlternateExchange.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,7 @@ public void handleReturn(int replyCode,
9898
protected void setupRouting(String name, String ae) throws IOException {
9999
Map<String, Object> args = new HashMap<String, Object>();
100100
if (ae != null) args.put("alternate-exchange", ae);
101+
channel.exchangeDelete(name);
101102
channel.exchangeDeclare(name, "direct", false, false, args);
102103
channel.queueBind(name, name, name);
103104
}

0 commit comments

Comments
 (0)