protected synchronized void onSendTaskCompleted(RecordBuffer<R> buffer){
  logger.trace("{}:{} Send Completed",name(),buffer);
  activeSendTasks.decrementAndGet();
}

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