Class ReplayService

java.lang.Object
be.looorent.jflu.store.ReplayService

public class ReplayService extends Object
This service can be used to read all events from the database and send them to the exchange with status=replay
  • Constructor Details

    • ReplayService

      public ReplayService(long firstEventId, be.looorent.jflu.publisher.EventPublisher eventPublisher)
  • Method Details

    • replay

      public void replay() throws be.looorent.jflu.store.ReplayException
      Throws:
      be.looorent.jflu.store.ReplayException
    • main

      public static final void main(String... args) throws be.looorent.jflu.store.ReplayException
      Throws:
      be.looorent.jflu.store.ReplayException