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)

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, registerMonitor, resetPosition, setRetentionTime, storePosition

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)

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