public void invokeHookBoltAck ( Tuple tuple , Duration processLatency ) { if ( taskHooks . size ( ) != 0 ) { BoltAckInfo ackInfo = new BoltAckInfo ( tuple , getThisTaskId ( ) , processLatency ) ; for ( ITaskHook taskHook : taskHooks ) { taskHook . boltAck ( ackInfo ) ; } } }
Task hook called in bolt every time a tuple gets acked