protected synchronized void onSendAccepted(RecordBuffer<R> buffer){
  logger.trace("{}:{} Send Scheduled",name(),buffer);
  throttler.onSendAccepted();
  activeSendTasks.incrementAndGet();
}

protected synchronized void onSendAccepted ( RecordBuffer < R > buffer ) { logger . trace ( "{}:{} Send Scheduled" , name ( ) , buffer ) ; throttler . onSendAccepted ( ) ; activeSendTasks . incrementAndGet ( ) ; }
this method should not raise any exceptions .
