ARTEMIS-179 - fix intermittent failure on BindingsClusterTest
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/BindingsClusterTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/BindingsClusterTest.java
index ba3e507..80f4c1a 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/BindingsClusterTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/cluster/BindingsClusterTest.java
@@ -335,6 +335,11 @@
printBindings(jmsServer1.getActiveMQServer(), TOPIC);
printBindings(jmsServer2.getActiveMQServer(), TOPIC);
+ // verify receipt by remote binding before crash
+ TextMessage received = (TextMessage) cons2.receive(5000);
+ assertNotNull(received);
+ assertEquals("m2", received.getText());
+
crash();
//this may or may not be closed, if the server was crashed then it would have been closed on failure.
@@ -357,7 +362,7 @@
prod1.send(session1.createTextMessage("m6"));
prod1.send(session1.createTextMessage("m7"));
- TextMessage received = (TextMessage) cons1.receive(5000);
+ received = (TextMessage) cons1.receive(5000);
assertNotNull(received);
