@Test
public void testManageAckStreamingOperationNoClustering() throws Exception {

    when(configurationContext.isClusteringEnabled()).thenReturn(false);
    final ClusterSyncManager partiallyMockedClusterSyncManager = PowerMockito.spy(new ClusterSyncManager(STREAMING
            .ZK_CLUSTER_MANAGER_PATH, "id", configurationContext, failOverTask, curatorFramework, zkUtils,
            clusterBarrierManager));
    doNothing().when(zkUtils).createZNodeJsonReply(any(StratioStreamingMessage.class), any(Object.class));
    ActionCallbackDto reply = partiallyMockedClusterSyncManager.manageAckStreamingOperation(message, nodeReply);
    assertEquals(nodeReply, reply);
}