Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
2.0-beta9
-
None
-
None
Description
In the TimeBasedTriggeringPolicy.java, it's using system current timestamp to compare with nextRollover time:
Code:
final long now = System.currentTimeMillis(); if (now > nextRollover) { ... ....
But I think, it should use the event time millis:
Code:
final long now = event.getMillis(); if (now > nextRollover) {... ...
According the event time millis, it can be System.currentTimeMillis or Message's timestamp if the message implements TimestampMessage.
So I think the event.getMillis() would be the best choice for comparing with nextRollover time.