ClusterSyncManager { public static ClusterSyncManager getNode() throws Exception { return self; } ClusterSyncManager(String latchpath, String id, ConfigurationContext
            configurationContext, FailOverTask failOverTask, CuratorFramework curatorClient, ZKUtils zkUtils,
            ClusterBarrierManager clusterBarrierManager);  ClusterSyncManager(String latchpath, String id, ConfigurationContext
            configurationContext, FailOverTask failOverTask); static ClusterSyncManager getClusterSyncManager(ConfigurationContext configurationContext,
            FailOverTask failOverTask); static ClusterSyncManager getNode(); void start(); boolean isStarted(); ActionCallbackDto manageAckStreamingOperation(StratioStreamingMessage message, ActionCallbackDto reply); String initializedNodeStatus(); String initializedGroupStatus(); String updateNodeStatus(String nodeId, PathChildrenCacheEvent.Type eventType); boolean isLeader(); CuratorFramework getClient(); String getGroupId();  }
@Test public void testGetNode() throws Exception { ClusterSyncManager.getClusterSyncManager(configurationContext, failOverTask); ClusterSyncManager clusterSyncManager = ClusterSyncManager.getNode(); assertNotNull(clusterSyncManager); assertThat(clusterSyncManager, instanceOf(ClusterSyncManager.class)); }