Package be.looorent.jflu.store

Class ReplayService

java.lang.Object
be.looorent.jflu.store.ReplayService
public class ReplayService
extends java.lang.Object
This service can be used to read all events from the database and send them to the exchange with status=replay

  • Constructor Summary

    Constructors 
    Constructor Description
    ReplayService​(long firstEventId, be.looorent.jflu.publisher.EventPublisher eventPublisher)  

  • Method Summary

    Modifier and Type Method Description
    static void main​(java.lang.String... args)  
    void replay()  

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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​(java.lang.String... args) throws be.looorent.jflu.store.ReplayException
      Throws:
      be.looorent.jflu.store.ReplayException