public void invokeHookSpoutAck ( Object messageId , Duration completeLatency ) { if ( taskHooks . size ( ) != 0 ) { SpoutAckInfo ackInfo = new SpoutAckInfo ( messageId , getThisTaskId ( ) , completeLatency ) ; for ( ITaskHook taskHook : taskHooks ) { taskHook . spoutAck ( ackInfo ) ; } } }
Task hook called in spout every time a tuple gets acked