8000 Be more proactive about cleaning up exchanges declared here · liborange/rabbitmq-java-client@1c7ef6f · GitHub
[go: up one dir, main page]

Skip to content

Commit 1c7ef6f

Browse files
Be more proactive about cleaning up exchanges declared here
1 parent cd13e7a commit 1c7ef6f

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)
0