public void process ( List < T > objects ) { for ( T message : objects ) { // If this batcher has been shutdown, do not accept any more // messages if ( isShutDown ) { return ; } process ( message ) ; } }
Processes the messages sent to the batcher . This method just writes the message to the queue and returns immediately . If the queue is full the messages are dropped immediately and corresponding counter is incremented .