Class LocalEventStoreClient

java.lang.Object

io.fluxzero.sdk.tracking.client.LocalTrackingClient

io.fluxzero.sdk.persisting.eventsourcing.client.LocalEventStoreClient

All Implemented Interfaces:

Monitored<List<SerializedMessage>>, HasMessageStore, EventStoreClient, GatewayClient, TrackingClient, AutoCloseable

public class LocalEventStoreClient
extends LocalTrackingClient
implements EventStoreClient

A client implementation for managing and storing events in an in-memory event store. The LocalEventStoreClient extends the LocalTrackingClient to leverage its tracking and gateway functionality while applying it specifically to event storage operations. It implements the EventStoreClient interface and serves as a lightweight, local event store client, primarily for testing or non-distributed environments.

Constructor Summary

Constructors

Constructor	Description
LocalEventStoreClient(Duration messageExpiration)
LocalEventStoreClient(Duration messageExpiration, Duration initialPositionLag)	Creates a local event store with a configurable look-back for consumers without a stored position.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes any open resources associated with this client.
InMemoryEventStore	getMessageStore()	Returns the associated MessageStore instance.

Methods inherited from class LocalTrackingClient

append, claimSegment, disconnectTracker, getPosition, read, readFromIndex, readFromIndex, readRange, readRange, registerMonitor, resetPosition, setRetentionTime, storePosition, truncate

Methods inherited from class Object

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

Methods inherited from interface EventStoreClient

deleteEvents, deleteEvents, getAggregateIds, getAggregatesFor, getEvents, getEvents, getEvents, getRelationships, getRelationships, repairRelationships, storeEvents, storeEvents, updateRelationships

Methods inherited from interface TrackingClient

disconnectTracker, getMessageType, getTopic, readAndWait, resetPosition, storePosition

Constructor Details

LocalEventStoreClient

public LocalEventStoreClient(Duration messageExpiration)

LocalEventStoreClient

public LocalEventStoreClient(Duration messageExpiration,
 Duration initialPositionLag)

Creates a local event store with a configurable look-back for consumers without a stored position.

Parameters:

messageExpiration - retention duration for local events

initialPositionLag - duration subtracted from the current time for a new consumer

Method Details

getMessageStore

public InMemoryEventStore getMessageStore()

Description copied from interface: HasMessageStore

Returns the associated MessageStore instance.

Specified by:

getMessageStore in interface HasMessageStore

close

public void close()

Description copied from interface: TrackingClient

Closes any open resources associated with this client.

Once closed, the client should no longer be used to fetch or commit tracking state.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface EventStoreClient

Specified by:

close in interface GatewayClient

Specified by:

close in interface TrackingClient

Overrides:

close in class LocalTrackingClient