public void invokeHookSpoutFail ( Object messageId , Duration failLatency ) { if ( taskHooks . size ( ) != 0 ) { SpoutFailInfo failInfo = new SpoutFailInfo ( messageId , getThisTaskId ( ) , failLatency ) ; for ( ITaskHook taskHook : taskHooks ) { taskHook . spoutFail ( failInfo ) ; } } }
Task hook called in spout every time a tuple gets failed