Package be.looorent.jflu.store

Class 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 Detail

      • ReplayService

        public ReplayService​(long firstEventId,
                     be.looorent.jflu.publisher.EventPublisher eventPublisher)

    • Method Detail

      • 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