Fix org.apache.cxf.transport.jms.RequestResponseTest test cases which fail with 'Can't receive the Conduit Message in 10 seconds'
@@ -94,7 +94,7 @@ public abstract class AbstractJMSTester {
addressSettings.setAutoCreateQueues(true);
addressSettings.setAutoDeleteQueues(false);
addressSettings.setAutoDeleteAddresses(false);
- config.setAddressesSettings(Collections.singletonMap("#", new AddressSettings()));
+ config.setAddressSettings(Collections.singletonMap("#", new AddressSettings()));
broker = new EmbeddedActiveMQ();
broker.setConfiguration(config);
SecurityConfiguration securityConfig = new SecurityConfiguration();
@@ -302,8 +302,10 @@ public abstract class AbstractJMSTester {
synchronized (inMessage) {
inMessage.wait(MAX_RECEIVE_TIME * 1000L);
}
+ if (null == inMessage.get()) {
assertNotNull("Can't receive the Conduit Message in " + MAX_RECEIVE_TIME + " seconds", inMessage.get());
}
+ }
return inMessage.getAndSet(null);
}
@@ -312,9 +314,11 @@ public abstract class AbstractJMSTester {
synchronized (destMessage) {
destMessage.wait(MAX_RECEIVE_TIME * 1000L);
}
+ if (null == destMessage.get()) {
assertNotNull("Can't receive the Destination message in " + MAX_RECEIVE_TIME + " seconds",
destMessage.get());
}
+ }
return destMessage.getAndSet(null);
}
