@Scheduled(initialDelay=10000,fixedDelay=2000) public void rolloutEventScheduler(){
  final Iterator<RolloutEventKey> rolloutIterator=rolloutEvents.iterator();
  while (rolloutIterator.hasNext()) {
    final RolloutEventKey eventKey=rolloutIterator.next();
    eventBus.post(new RolloutChangeEvent(1,eventKey.tenant,eventKey.rolloutId));
    rolloutIterator.remove();
  }
  final Iterator<RolloutEventKey> rolloutGroupIterator=rolloutGroupEvents.iterator();
  while (rolloutGroupIterator.hasNext()) {
    final RolloutEventKey eventKey=rolloutGroupIterator.next();
    eventBus.post(new RolloutGroupChangeEvent(1,eventKey.tenant,eventKey.rolloutId,eventKey.rolloutGroupId));
    rolloutGroupIterator.remove();
  }
}

@ Scheduled ( initialDelay = 10000 , fixedDelay = 2000 ) public void rolloutEventScheduler ( ) { final Iterator < RolloutEventKey > rolloutIterator = rolloutEvents . iterator ( ) ; while ( rolloutIterator . hasNext ( ) ) { final RolloutEventKey eventKey = rolloutIterator . next ( ) ; eventBus . post ( new RolloutChangeEvent ( 1 , eventKey . tenant , eventKey . rolloutId ) ) ; rolloutIterator . remove ( ) ; } final Iterator < RolloutEventKey > rolloutGroupIterator = rolloutGroupEvents . iterator ( ) ; while ( rolloutGroupIterator . hasNext ( ) ) { final RolloutEventKey eventKey = rolloutGroupIterator . next ( ) ; eventBus . post ( new RolloutGroupChangeEvent ( 1 , eventKey . tenant , eventKey . rolloutId , eventKey . rolloutGroupId ) ) ; rolloutGroupIterator . remove ( ) ; } }
checks if there are events to publish in the fixed interval .
