protected synchronized void onSendRejected(RecordBuffer<R> buffer){
  logger.trace("{}:{} Send Rejected",name(),buffer);
  totalRejectedSendTasks.incrementAndGet();
  throttler.onSendRejected();
  queueBufferForRetry(buffer);
}

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