protected void onSendSuccess(RecordBuffer<R> buffer){
  sendSuccess.incrementAndGet();
  logger.trace("{}:{} Send SUCCESS",name(),buffer);
  try {
    checkpointer.saveCheckpoint(buffer);
  }
 catch (  Exception e) {
    logger.error("{}:{} Error in onSendSuccess",name(),buffer,e);
  }
}

protected void onSendSuccess ( RecordBuffer < R > buffer ) { sendSuccess . incrementAndGet ( ) ; logger . trace ( "{}:{} Send SUCCESS" , name ( ) , buffer ) ; try { checkpointer . saveCheckpoint ( buffer ) ; } catch ( Exception e ) { logger . error ( "{}:{} Error in onSendSuccess" , name ( ) , buffer , e ) ; } }
this method should not raise any exceptions .
