private void startClient(){
  if (flumeClient != null && !flumeClient.isActive()) {
    flumeClient.close();
    flumeClient=null;
  }
  if (flumeClient == null) {
    try {
      flumeClient=RpcClientFactory.getDefaultInstance(flumeHostName,flumePort,maxSpanBatchSize);
    }
 catch (    FlumeException e) {
      LOG.warn("Failed to create Flume RPC Client. " + e.getMessage());
    }
  }
}

private void startClient ( ) { if ( flumeClient != null && ! flumeClient . isActive ( ) ) { flumeClient . close ( ) ; flumeClient = null ; } if ( flumeClient == null ) { try { flumeClient = RpcClientFactory . getDefaultInstance ( flumeHostName , flumePort , maxSpanBatchSize ) ; } catch ( FlumeException e ) { LOG . warn ( "Failed to create Flume RPC Client. " + e . getMessage ( ) ) ; } } }
create / reconnect flume rpc client
