question: private void scheduleSend ( final int queueSize ) { if ( pending ) { return ; } if ( queueSize >= batchSize ) { enqueueSend ( ) ; return ; } if ( scheduled . compareAndSet ( false , true ) ) { try { scheduler . schedule ( null , maxLatencyMs , MILLISECONDS ) ; schedulerQueueSize . incrementAndGet ( ) ; } catch ( RejectedExecutionException ignore ) { } } }
target:  Schedule this topic for future enqueuing for batch sending. If the batch size has been reached, enqueue for sending immediately.