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

SessionCloseOnGCTest#testCloseOneSessionOnGC avoiding intermittent failure

This commit is contained in:
Clebert Suconic 2015-10-26 11:10:48 -04:00
parent 15b8b8138b
commit bd946d2ce8
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SessionCloseOnGCTest.java
View File

@ -16,6 +16,8 @@
*/ */
package org.apache.activemq.artemis.tests.integration.client; package org.apache.activemq.artemis.tests.integration.client;
import java.lang.ref.WeakReference;
import org.apache.activemq.artemis.api.core.client.ClientSession; import org.apache.activemq.artemis.api.core.client.ClientSession;
import org.apache.activemq.artemis.api.core.client.ClientSessionFactory; import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
import org.apache.activemq.artemis.api.core.client.ServerLocator; import org.apache.activemq.artemis.api.core.client.ServerLocator;
@ -26,8 +28,6 @@ import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import java.lang.ref.WeakReference;
public class SessionCloseOnGCTest extends ActiveMQTestBase { public class SessionCloseOnGCTest extends ActiveMQTestBase {
private ActiveMQServer server; private ActiveMQServer server;
@ -191,6 +191,12 @@ public class SessionCloseOnGCTest extends ActiveMQTestBase {
ActiveMQTestBase.checkWeakReferences(wses); ActiveMQTestBase.checkWeakReferences(wses);
for (int i = 0; i < 100 && sf.numSessions() != 0; i++) {
System.gc();
System.runFinalization();
Thread.sleep(100);
}
Assert.assertEquals(0, sf.numSessions()); Assert.assertEquals(0, sf.numSessions());
Assert.assertEquals(1, sf.numConnections()); Assert.assertEquals(1, sf.numConnections());
Assert.assertEquals(1, server.getRemotingService().getConnections().size()); Assert.assertEquals(1, server.getRemotingService().getConnections().size());