Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA: fixing a test

This commit is contained in:
Clebert Suconic 2017-01-30 15:55:05 -05:00
parent 3480cc7104
commit 57945d97e9
3 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTestWithInterceptors.java
View File

@ -29,6 +29,7 @@ import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger;
import org.apache.activemq.artemis.tests.integration.stomp.util.ClientStompFrame; import org.apache.activemq.artemis.tests.integration.stomp.util.ClientStompFrame;
import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnection; import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnection;
import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnectionFactory; import org.apache.activemq.artemis.tests.integration.stomp.util.StompClientConnectionFactory;
import org.apache.activemq.artemis.tests.util.Wait;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
@ -105,7 +106,13 @@ public class StompTestWithInterceptors extends StompTestBase {
Thread.sleep(10); Thread.sleep(10);
} }
Wait.waitFor(() -> {
return MyIncomingStompFrameInterceptor.incomingInterceptedFrames.size() == 4;
});
Assert.assertEquals(4, MyIncomingStompFrameInterceptor.incomingInterceptedFrames.size()); Assert.assertEquals(4, MyIncomingStompFrameInterceptor.incomingInterceptedFrames.size());
Wait.waitFor(() -> {
return MyOutgoingStompFrameInterceptor.outgoingInterceptedFrames.size() == 3;
});
Assert.assertEquals(3, MyOutgoingStompFrameInterceptor.outgoingInterceptedFrames.size()); Assert.assertEquals(3, MyOutgoingStompFrameInterceptor.outgoingInterceptedFrames.size());
for (int i = 0; i < MyIncomingStompFrameInterceptor.incomingInterceptedFrames.size(); i++) { for (int i = 0; i < MyIncomingStompFrameInterceptor.incomingInterceptedFrames.size(); i++) {

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/AbstractStompClientConnection.java
View File

@ -78,7 +78,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
private ClientStompFrame sendFrameInternal(ClientStompFrame frame, boolean wicked) throws IOException, InterruptedException { private ClientStompFrame sendFrameInternal(ClientStompFrame frame, boolean wicked) throws IOException, InterruptedException {
ClientStompFrame response = null; ClientStompFrame response = null;
IntegrationTestLogger.LOGGER.info("Sending " + (wicked ? "*wicked* " : "") + "frame:\n" + frame); IntegrationTestLogger.LOGGER.trace("Sending " + (wicked ? "*wicked* " : "") + "frame:\n" + frame);
ByteBuffer buffer; ByteBuffer buffer;
if (wicked) { if (wicked) {
buffer = frame.toByteBufferWithExtra("\n"); buffer = frame.toByteBufferWithExtra("\n");
@ -103,7 +103,7 @@ public abstract class AbstractStompClientConnection implements StompClientConnec
} }
} }
IntegrationTestLogger.LOGGER.info("Received:\n" + response); IntegrationTestLogger.LOGGER.trace("Received:\n" + response);
return response; return response;
} }

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/util/StompClientConnectionV11.java
View File

@ -81,7 +81,7 @@ public class StompClientConnectionV11 extends StompClientConnectionV10 {
this.passcode = passcode; this.passcode = passcode;
this.connected = true; this.connected = true;
} else { } else {
System.out.println("Connection failed with frame " + response); System.err.println("Connection failed with frame " + response);
connected = false; connected = false;
} }
} }