void batchReady ( String batch ) { if ( log . isDebugEnabled ( ) ) { log . debug ( String . format ( "%s - Batch ready: Batch[batch=%s]" , this , batch ) ) ; } eventBus . send ( outAddress , new JsonObject ( ) . putString ( "action" , "batch" ) . putString ( "batch" , batch ) ) ; }
Indicates that an input batch is ready .