// TODO Your code..
@Override
        public void run() {
            logger.info("START ZookeeperRiverLogic: " + client.toString());
            // TODO Your code..
        }
public void run() {
logger.info("START ZookeeperRiverLogic: " + client.toString());
// TODO Your code..
}
@Override
public void run() {
logger.info("START ZookeeperRiverLogic: " + client.toString());
// TODO Your code..
}
@Override
public void run() {
logger.info("START ZookeeperRiverLogic: " + client.toString());
// TODO Your code..
}