Class CollectionMessageStore

java.lang.Object

io.fluxzero.sdk.persisting.search.client.CollectionMessageStore

All Implemented Interfaces:

AutoCloseable

public class CollectionMessageStore
extends Object

A MessageStore implementation backed by a collection in an InMemorySearchStore. This class provides functionality for tracking updated documents in a specific collection.

Used to support HandleDocument from in-memory search stores.

Constructor Summary

Constructors

Constructor	Description
CollectionMessageStore()

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> messages)
default void	close()
default List<io.fluxzero.common.api.SerializedMessage>	getBatch(Long arg0, int arg1)
List<io.fluxzero.common.api.SerializedMessage>	getBatch(Long minIndex, int maxSize, boolean inclusive)
default io.fluxzero.common.tracking.MessageStore	getMessageStore()
io.fluxzero.common.Registration	registerMonitor(Consumer<List<io.fluxzero.common.api.SerializedMessage>> monitor)
void	setRetentionTime(Duration retentionPeriod)
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

CollectionMessageStore

public CollectionMessageStore()

Method Details

getBatch

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

registerMonitor

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

append

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

setRetentionTime

public void setRetentionTime(Duration retentionPeriod)

truncate

public void truncate()

append

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

getBatch

default List<io.fluxzero.common.api.SerializedMessage> getBatch(Long arg0,
 int arg1)

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()