public void remove(QueueEvent event) throws KeeperException, InterruptedException {
  TimerContext time=stats.time(dir + "_remove_event");
  try {
    String path=event.getId();
    String responsePath=dir + "/" + response_prefix+ path.substring(path.lastIndexOf("-") + 1);
    if (zookeeper.exists(responsePath,true)) {
      zookeeper.setData(responsePath,event.getBytes(),true);
    }
 else {
      LOG.info("Response ZK path: " + responsePath + " doesn't exist."+ "  Requestor may have disconnected from ZooKeeper");
    }
    try {
      zookeeper.delete(path,-1,true);
    }
 catch (    KeeperException.NoNodeException ignored) {
    }
  }
  finally {
    time.stop();
  }
}

public void remove ( QueueEvent event ) throws KeeperException , InterruptedException { TimerContext time = stats . time ( dir + "_remove_event" ) ; try { String path = event . getId ( ) ; String responsePath = dir + "/" + response_prefix + path . substring ( path . lastIndexOf ( "-" ) + 1 ) ; if ( zookeeper . exists ( responsePath , true ) ) { zookeeper . setData ( responsePath , event . getBytes ( ) , true ) ; } else { LOG . info ( "Response ZK path: " + responsePath + " doesn't exist." + "  Requestor may have disconnected from ZooKeeper" ) ; } try { zookeeper . delete ( path , - 1 , true ) ; } catch ( KeeperException . NoNodeException ignored ) { } } finally { time . stop ( ) ; } }
remove the event and save the response into the other path .
