Module io.fluxzero.sdk

Package io.fluxzero.sdk.scheduling.client

Class LocalSchedulingClient

java.lang.Object

io.fluxzero.sdk.tracking.client.LocalTrackingClient

io.fluxzero.sdk.scheduling.client.LocalSchedulingClient

All Implemented Interfaces:

io.fluxzero.common.Monitored<List<io.fluxzero.common.api.SerializedMessage>>, io.fluxzero.common.tracking.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()

Methods inherited from class io.fluxzero.sdk.tracking.client.LocalTrackingClient

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.fluxzero.sdk.scheduling.client.SchedulingClient

cancelSchedule, cancelSchedule, getSchedule, hasSchedule, schedule, schedule

Methods inherited from interface io.fluxzero.sdk.tracking.client.TrackingClient

disconnectTracker, getMessageType, getTopic, readAndWait, resetPosition, storePosition

Constructor Details

LocalSchedulingClient

public LocalSchedulingClient(Duration messageExpiration)

Method Details

getMessageStore

public InMemoryScheduleStore getMessageStore()

Specified by:

getMessageStore in interface io.fluxzero.common.tracking.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