public void cancel(RpcCancel rpcCancel){
  int correlationId=rpcCancel.getCorrelationId();
  if (callExecutor == null) {
    return;
  }
  PendingServerCallState state=pendingServerCallMap.remove(correlationId);
  if (state != null) {
    callExecutor.cancel(state.getExecutor());
    if (log.isDebugEnabled()) {
      log.debug("Received [" + rpcCancel.getCorrelationId() + "]RpcCancel.");
    }
    doLog(state,rpcCancel,"Cancelled");
  }
}

public void cancel ( RpcCancel rpcCancel ) { int correlationId = rpcCancel . getCorrelationId ( ) ; if ( callExecutor == null ) { return ; } PendingServerCallState state = pendingServerCallMap . remove ( correlationId ) ; if ( state != null ) { callExecutor . cancel ( state . getExecutor ( ) ) ; if ( log . isDebugEnabled ( ) ) { log . debug ( "Received [" + rpcCancel . getCorrelationId ( ) + "]RpcCancel." ) ; } doLog ( state , rpcCancel , "Cancelled" ) ; } }
on cancel from the client , the rpcserver does not expect to receive a callback anymore from the rpcservercallexecutor .
