Package io.fluxcapacitor.common.tracking

Interface MessageStore

All Superinterfaces:

AutoCloseable, HasMessageStore, Monitored<List<SerializedMessage>>

public interface MessageStore
extends AutoCloseable, Monitored<List<SerializedMessage>>, HasMessageStore

Method Summary

Modifier and Type	Method	Description
default CompletableFuture<Void>	append(SerializedMessage... messages)
CompletableFuture<Void>	append(List<SerializedMessage> messages)
default void	close()
default List<SerializedMessage>	getBatch(Long minIndex, int maxSize)
List<SerializedMessage>	getBatch(Long minIndex, int maxSize, boolean inclusive)
default MessageStore	getMessageStore()
void	setRetentionTime(Duration retentionPeriod)
default <T extends MessageStore> T	unwrap(Class<T> type)

Methods inherited from interface io.fluxcapacitor.common.Monitored

registerMonitor

Method Details

append

default CompletableFuture<Void> append(SerializedMessage... messages)

append

CompletableFuture<Void> append(List<SerializedMessage> messages)

getBatch

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

getBatch

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

setRetentionTime

void setRetentionTime(Duration retentionPeriod)

unwrap

default <T extends MessageStore> T unwrap(Class<T> type)

close

default void close()

Specified by:

close in interface AutoCloseable

getMessageStore

default MessageStore getMessageStore()

Specified by:

getMessageStore in interface HasMessageStore