class ClusterSyncManager {

    public String initializedNodeStatus() throws Exception {

        String nodeStatusPath;

        if (!clusteringEnabled){
            nodeStatusPath = STREAMING.ZK_EPHEMERAL_NODE_STATUS_PATH;
        }
        else {
            nodeStatusPath = STREAMING.ZK_EPHEMERAL_GROUPS_STATUS_BASE_PATH.concat("/").concat(STREAMING.GROUPS_STATUS_BASE_PREFIX)
                    .concat(groupId);
        }

        zkUtils.createEphemeralZNode(nodeStatusPath, STREAMING.ZK_EPHEMERAL_NODE_STATUS_INITIALIZED.getBytes());

        return nodeStatusPath;

    }

    public  ClusterSyncManager(String latchpath, String id, ConfigurationContext
            configurationContext, FailOverTask failOverTask, CuratorFramework curatorClient, ZKUtils zkUtils,
            ClusterBarrierManager clusterBarrierManager);
    public  ClusterSyncManager(String latchpath, String id, ConfigurationContext
            configurationContext, FailOverTask failOverTask);

}