Skip to content

Commit 3360738

Browse files
committed
Fix FailoverTestBase
1 parent 6e7f73d commit 3360738

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

  • tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTestBase.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -446,6 +446,10 @@ protected ClientSessionFactoryInternal createSessionFactoryAndWaitForTopology(Se
446446
ClientSessionFactoryInternal sf = (ClientSessionFactoryInternal) locator.createSessionFactory();
447447
addSessionFactory(sf);
448448

449+
if (primaryConfig.isSecurityEnabled()) {
450+
createSession(sf, true, true, sf.getServerLocator().getAckBatchSize()).close();
451+
}
452+
449453
assertTrue(countDownLatch.await(5, TimeUnit.SECONDS), "topology members expected " + topologyMembers);
450454
return sf;
451455
}

0 commit comments

Comments
 (0)