private boolean onQueueBufferSuccess(RecordBuffer<R> buffer,long elapsed){
  queuedRecords+=buffer.sizeRecords();
  queuedBytes+=buffer.sizeBytesWithOverhead();
  totalQueueWaitTimeMillis.addAndGet(elapsed);
  notEmpty.signal();
  return true;
}

private boolean onQueueBufferSuccess ( RecordBuffer < R > buffer , long elapsed ) { queuedRecords += buffer . sizeRecords ( ) ; queuedBytes += buffer . sizeBytesWithOverhead ( ) ; totalQueueWaitTimeMillis . addAndGet ( elapsed ) ; notEmpty . signal ( ) ; return true ; }
keep private . call only when holding lock .
