ARTEMIS-5173 Trying another test fix
This commit is contained in:
parent
a2357b9d6d
commit
c680356717
|
@ -70,6 +70,7 @@ import org.apache.activemq.artemis.utils.ConfirmationWindowWarning;
|
|||
import org.apache.activemq.artemis.utils.ExecutorFactory;
|
||||
import org.apache.activemq.artemis.utils.PasswordMaskingUtil;
|
||||
import org.apache.activemq.artemis.utils.UUIDGenerator;
|
||||
import org.apache.activemq.artemis.utils.actors.ArtemisExecutor;
|
||||
import org.apache.activemq.artemis.utils.actors.OrderedExecutorFactory;
|
||||
import org.apache.activemq.artemis.utils.collections.ConcurrentHashSet;
|
||||
import org.slf4j.Logger;
|
||||
|
@ -117,7 +118,7 @@ public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, C
|
|||
|
||||
private final ScheduledExecutorService scheduledThreadPool;
|
||||
|
||||
private final Executor closeExecutor;
|
||||
private final ArtemisExecutor closeExecutor;
|
||||
|
||||
private final Executor flowControlExecutor;
|
||||
|
||||
|
@ -1566,4 +1567,8 @@ public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, C
|
|||
serverLocator.notifyNodeDown(eventTime, nodeID, disconnect);
|
||||
}
|
||||
}
|
||||
|
||||
public void flushCloseExecutor(int time, TimeUnit unit) {
|
||||
closeExecutor.flush(time, unit);
|
||||
}
|
||||
}
|
||||
|
|
|
@ -31,6 +31,7 @@ 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.FailoverEventType;
|
||||
import org.apache.activemq.artemis.api.core.client.ServerLocator;
|
||||
import org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl;
|
||||
import org.apache.activemq.artemis.core.config.ha.ReplicaPolicyConfiguration;
|
||||
import org.apache.activemq.artemis.core.config.ha.ReplicationBackupPolicyConfiguration;
|
||||
import org.apache.activemq.artemis.core.server.ActiveMQServer;
|
||||
|
@ -160,6 +161,7 @@ public class ReplicatedMultipleServerFailoverExtraBackupsTest extends Replicated
|
|||
CountDownLatch failoverHappened = new CountDownLatch(1);
|
||||
|
||||
session0.addFailoverListener((FailoverEventType type) -> {
|
||||
new Exception("Type::" + type).printStackTrace();
|
||||
if (type == FailoverEventType.FAILOVER_COMPLETED) {
|
||||
failoverHappened.countDown();
|
||||
}
|
||||
|
@ -173,6 +175,9 @@ public class ReplicatedMultipleServerFailoverExtraBackupsTest extends Replicated
|
|||
|
||||
assertTrue(failoverHappened.await(10, TimeUnit.SECONDS));
|
||||
|
||||
((ClientSessionFactoryImpl)session0.getSessionFactory()).flushCloseExecutor(10, TimeUnit.SECONDS);
|
||||
((ClientSessionFactoryImpl)session1.getSessionFactory()).flushCloseExecutor(10, TimeUnit.SECONDS);
|
||||
|
||||
ClientConsumer consumer0 = session0.createConsumer(ADDRESS);
|
||||
ClientConsumer consumer1 = session1.createConsumer(ADDRESS);
|
||||
session0.start();
|
||||
|
|
Loading…
Reference in New Issue