Class LocalSchedulingClient

java.lang.Object

io.fluxzero.sdk.tracking.client.LocalTrackingClient

io.fluxzero.sdk.scheduling.client.LocalSchedulingClient

All Implemented Interfaces:

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

public class LocalSchedulingClient
extends LocalTrackingClient
implements SchedulingClient

A client implementation for managing scheduling operations using an in-memory schedule store. This class extends LocalTrackingClient and implements the SchedulingClient interface. It serves as a local, non-distributed scheduling client primarily useful for testing scenarios or where an in-memory schedule store suffices.

Constructor Summary

Constructors

Constructor	Description
LocalSchedulingClient(Duration messageExpiration)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes any open resources associated with this client.
InMemoryScheduleStore	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 SchedulingClient

cancelSchedule, cancelSchedule, getSchedule, hasSchedule, schedule, schedule

Methods inherited from interface TrackingClient

disconnectTracker, getMessageType, getTopic, readAndWait, resetPosition, storePosition

Constructor Details

LocalSchedulingClient

public LocalSchedulingClient(Duration messageExpiration)

Method Details

getMessageStore

public InMemoryScheduleStore 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 GatewayClient

Specified by:

close in interface SchedulingClient

Specified by:

close in interface TrackingClient

Overrides:

close in class LocalTrackingClient