Class TestServerScheduleStore

java.lang.Object

io.fluxzero.testserver.scheduling.TestServerScheduleStore

All Implemented Interfaces:

AutoCloseable

public class TestServerScheduleStore
extends Object

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
default CompletableFuture<Void>	append(io.fluxzero.common.api.SerializedMessage... arg0)
CompletableFuture<Void>	append(List<io.fluxzero.common.api.SerializedMessage> arg0)
default CompletableFuture<Void>	cancelSchedule(String arg0)
CompletableFuture<Void>	cancelSchedule(String arg0, io.fluxzero.common.Guarantee arg1)
default void	close()
void	close()
List<io.fluxzero.common.api.SerializedMessage>	getBatch(Long minIndex, int maxSize)
List<io.fluxzero.common.api.SerializedMessage>	getBatch(Long minIndex, int maxSize, boolean inclusive)
default io.fluxzero.common.tracking.MessageStore	getMessageStore()
io.fluxzero.common.api.scheduling.SerializedSchedule	getSchedule(String arg0)
default boolean	hasSchedule(String arg0)
io.fluxzero.common.Registration	registerMonitor(Consumer<List<io.fluxzero.common.api.SerializedMessage>> arg0)
protected void	rescheduleNextDeadline(long nextIndex)
default CompletableFuture<Void>	schedule(io.fluxzero.common.api.scheduling.SerializedSchedule... arg0)
CompletableFuture<Void>	schedule(io.fluxzero.common.Guarantee guarantee, io.fluxzero.common.api.scheduling.SerializedSchedule... schedules)
void	setRetentionTime(Duration arg0)
void	truncate()
default <T extends io.fluxzero.common.tracking.MessageStore> T	unwrap(Class<T> arg0)

Methods inherited from class Object

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

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)

getBatch

public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex,
 int maxSize)

getBatch

public List<io.fluxzero.common.api.SerializedMessage> getBatch(Long minIndex,
 int maxSize,
 boolean inclusive)

rescheduleNextDeadline

protected void rescheduleNextDeadline(long nextIndex)

truncate

public void truncate()

append

default CompletableFuture<Void> append(io.fluxzero.common.api.SerializedMessage... arg0)

append

CompletableFuture<Void> append(List<io.fluxzero.common.api.SerializedMessage> arg0)

setRetentionTime

void setRetentionTime(Duration arg0)

unwrap

default <T extends io.fluxzero.common.tracking.MessageStore>
T unwrap(Class<T> arg0)

close

default void close()

Specified by:

close in interface AutoCloseable

getMessageStore

default io.fluxzero.common.tracking.MessageStore getMessageStore()

registerMonitor

io.fluxzero.common.Registration registerMonitor(Consumer<List<io.fluxzero.common.api.SerializedMessage>> arg0)

schedule

default CompletableFuture<Void> schedule(io.fluxzero.common.api.scheduling.SerializedSchedule... arg0)

cancelSchedule

default CompletableFuture<Void> cancelSchedule(String arg0)

cancelSchedule

CompletableFuture<Void> cancelSchedule(String arg0,
 io.fluxzero.common.Guarantee arg1)

hasSchedule

default boolean hasSchedule(String arg0)

getSchedule

io.fluxzero.common.api.scheduling.SerializedSchedule getSchedule(String arg0)

close

void close()

Specified by:

close in interface AutoCloseable