void put ( final AbstractBatchEntry batchEntry ) { try { this . queue . put ( batchEntry ) ; } catch ( InterruptedException e ) { throw new RuntimeException ( e ) ; } if ( this . queue . size ( ) >= this . actions ) { this . scheduler . submit ( new Runnable ( ) { @ Override public void run ( ) { write ( ) ; } } ) ; } }
Put a single BatchEntry to the cache for later processing .