CountDownSessionFailureListener listener = new CountDownSessionFailureListener(latch);
session.addFailureListener(listener);
}
ClusterManager clusterManager = server.getClusterManager();
clusterManager.flushExecutor();
((ClusterManagerImpl)clusterManager).clear();
Assert.assertTrue("server should be running!", server.isStarted());
server.stop(true);
if (sessions.length > 0)