void doBatchEnd ( String batch , Object args ) { checkOpen ( ) ; JsonObject message = createMessage ( args ) . putString ( "action" , "endBatch" ) . putString ( "batch" , batch ) ; if ( open && ! paused ) { if ( log . isDebugEnabled ( ) ) { log . debug ( String . format ( "%s - Batch end: Batch[batch=%s, args=%s]" , this , batch , args ) ) ; } eventBus . send ( inAddress , message ) ; } if ( currentBatch != null && currentBatch . id ( ) . equals ( batch ) ) { currentBatch = null ; } }
Sends a batch end message .