Module io.fluxzero.testserver
Package io.fluxzero.testserver.scheduling

Class TestServerScheduleStore

java.lang.Object
io.fluxzero.testserver.scheduling.TestServerScheduleStore
All Implemented Interfaces:
io.fluxzero.common.Monitored<List<io.fluxzero.common.api.SerializedMessage>>, io.fluxzero.common.tracking.HasMessageStore, io.fluxzero.common.tracking.MessageStore, io.fluxzero.sdk.scheduling.client.SchedulingClient, AutoCloseable
public class TestServerScheduleStore extends Object implements io.fluxzero.common.tracking.MessageStore, io.fluxzero.sdk.scheduling.client.SchedulingClient

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestServerScheduleStore(io.fluxzero.sdk.scheduling.client.InMemoryScheduleStore delegate)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    List<io.fluxzero.common.api.SerializedMessage>
    getBatch(Long minIndex, int maxSize)
     
    List<io.fluxzero.common.api.SerializedMessage>
    getBatch(Long minIndex, int maxSize, boolean inclusive)
     
    protected void
    rescheduleNextDeadline(long nextIndex)
     
    CompletableFuture<Void>
    schedule(io.fluxzero.common.Guarantee guarantee, io.fluxzero.common.api.scheduling.SerializedSchedule... schedules)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.fluxzero.common.tracking.MessageStore

    append, append, close, getMessageStore, setRetentionTime, unwrap

    Methods inherited from interface io.fluxzero.common.Monitored

    registerMonitor

    Methods inherited from interface io.fluxzero.sdk.scheduling.client.SchedulingClient

    cancelSchedule, cancelSchedule, close, getSchedule, hasSchedule, schedule

  • Constructor Details

    • TestServerScheduleStore

      public TestServerScheduleStore(io.fluxzero.sdk.scheduling.client.InMemoryScheduleStore delegate)

  • Method Details

    • schedule

      public CompletableFuture<Void> schedule(io.fluxzero.common.Guarantee guarantee, io.fluxzero.common.api.scheduling.SerializedSchedule... schedules)
      Specified by:
      schedule in interface io.fluxzero.sdk.scheduling.client.SchedulingClient

    • getBatch

      public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex, int maxSize)
      Specified by:
      getBatch in interface io.fluxzero.common.tracking.MessageStore

    • getBatch

      public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex, int maxSize, boolean inclusive)
      Specified by:
      getBatch in interface io.fluxzero.common.tracking.MessageStore

    • rescheduleNextDeadline

      protected void rescheduleNextDeadline(long nextIndex)