Class TestServerScheduleStore

java.lang.Object

io.fluxzero.testserver.scheduling.TestServerScheduleStore

All Implemented Interfaces:

Monitored<List<SerializedMessage>>, HasMessageStore, MessageStore, SchedulingClient, AutoCloseable

public class TestServerScheduleStore
extends Object
implements MessageStore, SchedulingClient

Constructor Summary

Constructors

Constructor	Description
TestServerScheduleStore(InMemoryScheduleStore delegate)

Method Summary

Modifier and Type	Method	Description
List<SerializedMessage>	getBatch(Long minIndex, int maxSize)	Retrieves a batch of messages starting from the given lastIndex (exclusive).
List<SerializedMessage>	getBatch(Long minIndex, int maxSize, boolean inclusive)	Retrieves a batch of messages starting from the given minIndex.
protected void	rescheduleNextDeadline(long nextIndex)
MessageStoreBatch	scanBatch(Long minIndex, int maxSize, boolean inclusive, long maxBytes, Predicate<? super SerializedMessage> filter)	Scans messages starting from the given minIndex, returning messages accepted by filter and metadata about the unfiltered source scan.
CompletableFuture<Void>	schedule(Guarantee guarantee, SerializedSchedule... schedules)	Schedule one or more serialized schedules with a specified Guarantee.
void	truncate()	Removes all messages from this store while keeping the logical log available for future appends.

Methods inherited from class Object

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

Methods inherited from interface MessageStore

append, append, close, getBatch, getBatch, getMessageStore, setRetentionTime, unwrap

Methods inherited from interface Monitored

registerMonitor

Methods inherited from interface SchedulingClient

cancelSchedule, cancelSchedule, close, getSchedule, hasSchedule, schedule

Constructor Details

TestServerScheduleStore

public TestServerScheduleStore(InMemoryScheduleStore delegate)

Method Details

schedule

public CompletableFuture<Void> schedule(Guarantee guarantee,
 SerializedSchedule... schedules)

Description copied from interface: SchedulingClient

Schedule one or more serialized schedules with a specified Guarantee.

Specified by:

schedule in interface SchedulingClient

Parameters:

guarantee - Delivery guarantee to apply (e.g., none, sent, stored).

schedules - One or more schedules to register.

Returns:

A future that completes when the scheduling is acknowledged.

getBatch

public List<SerializedMessage> getBatch(Long minIndex,
 int maxSize)

Description copied from interface: MessageStore

Retrieves a batch of messages starting from the given lastIndex (exclusive).

Specified by:

getBatch in interface MessageStore

Parameters:

minIndex - minimum message index to start from (exclusive)

maxSize - maximum number of messages to retrieve

Returns:

a list of SerializedMessage instances

getBatch

public List<SerializedMessage> getBatch(Long minIndex,
 int maxSize,
 boolean inclusive)

Description copied from interface: MessageStore

Retrieves a batch of messages starting from the given minIndex.

Specified by:

getBatch in interface MessageStore

Parameters:

minIndex - minimum message index to start from

maxSize - maximum number of messages to retrieve

inclusive - whether to include the message at minIndex

Returns:

a list of SerializedMessage instances

scanBatch

public MessageStoreBatch scanBatch(Long minIndex,
 int maxSize,
 boolean inclusive,
 long maxBytes,
 Predicate<? super SerializedMessage> filter)

Description copied from interface: MessageStore

Scans messages starting from the given minIndex, returning messages accepted by filter and metadata about the unfiltered source scan.

maxSize limits the number of source messages scanned. maxBytes limits the cumulative serialized payload bytes of accepted messages. If the first accepted message is larger than maxBytes, it is still returned so consumers can make progress.

Specified by:

scanBatch in interface MessageStore

Parameters:

minIndex - minimum message index to start from

maxSize - maximum number of source messages to scan

inclusive - whether to include the message at minIndex

maxBytes - maximum number of accepted serialized payload bytes, or 0 for no byte limit

filter - predicate deciding which messages enter the returned batch

Returns:

accepted messages and source scan metadata

rescheduleNextDeadline

protected void rescheduleNextDeadline(long nextIndex)

truncate

public void truncate()

Description copied from interface: MessageStore

Removes all messages from this store while keeping the logical log available for future appends.

Specified by:

truncate in interface MessageStore