We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ff49a79 commit a9b76f4Copy full SHA for a9b76f4
test/src/com/rabbitmq/client/test/server/AbsentQueue.java
@@ -83,8 +83,9 @@ protected void assertNotFound(Task t) throws IOException {
83
if (clusteredChannel == null) return;
84
try {
85
t.run();
86
- fail("expected not_found");
+ if (!HATests.HA_TESTS_RUNNING) fail("expected not_found");
87
} catch (IOException ioe) {
88
+ assertFalse(HATests.HA_TESTS_RUNNING);
89
checkShutdownSignal(AMQP.NOT_FOUND, ioe);
90
channel = connection.createChannel();
91
}
0 commit comments