question: public byte [ ] 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 ) ; } byte [ ] data = zookeeper . getData ( path , null , null , true ) ; zookeeper . delete ( path , - 1 , true ) ; return data ; } finally { time . stop ( ) ; } }
target:  Remove the event and save the response into the other path.