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

Add test case for ARTEMIS-231 

The test doesn't actually fail, but the test output shows the problem.
This commit is contained in:
Julian Scheid 2015-09-24 22:05:33 +02:00 committed by Clebert Suconic
parent 6956d14125
commit 2d679e9071
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompConnectionCleanupTest.java
View File

@ -28,6 +28,49 @@ public class StompConnectionCleanupTest extends StompTestBase {
private static final long CONNECTION_TTL = 2000;
// ARTEMIS-231
@Test
public void testConnectionCleanupWithTopicSubscription() throws Exception {
String frame = "CONNECT\n" + "login: brianm\n" + "passcode: wombats\n\n" + Stomp.NULL;
sendFrame(frame);
frame = receiveFrame(10000);
//We send and consumer a message to ensure a STOMP connection and server session is created
System.out.println("Received frame: " + frame);
assertTrue(frame.startsWith("CONNECTED"));
frame = "SUBSCRIBE\n" + "destination:" + getTopicPrefix() + getTopicName() + "\n" + "ack:auto\n\n" + Stomp.NULL;
sendFrame(frame);
frame = "DISCONNECT\n\n" + Stomp.NULL;
sendFrame(frame);
// Now we wait until the connection is cleared on the server, which will happen some time after ttl, since no data
// is being sent
long start = System.currentTimeMillis();
while (true) {
int connCount = server.getActiveMQServer().getRemotingService().getConnections().size();
int sessionCount = server.getActiveMQServer().getSessions().size();
// All connections and sessions should be timed out including STOMP + JMS connection
if (connCount == 0 && sessionCount == 0) {
break;
}
Thread.sleep(10);
if (System.currentTimeMillis() - start > 10000) {
fail("Timed out waiting for connection to be cleared up");
}
}
}
@Test
public void testConnectionCleanup() throws Exception {
String frame = "CONNECT\n" + "login: brianm\n" + "passcode: wombats\n\n" + Stomp.NULL;