I am effectively trying to simulate processing windows - drop the results that are not complete in time and was trying to use onTimer method in my Processor implementation. I am not sure that I understand exactly how this works. When I start execution (in a different processor) I am executing ctx.timerService.registerEventTimeTimer(currentTime + speculativeTimeout.value()) Basically the absolute cut off time.
Is this the right usage? What is happening when I have more then on timer started? Boris Lublinsky FDP Architect boris.lublin...@lightbend.com https://www.lightbend.com/
