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)
LocalSchedulingClient(Duration messageExpiration, Clock clock)
LocalSchedulingClient(Duration messageExpiration, Clock clock, Duration initialPositionLag)	Creates a clock-controlled local scheduling client with a configurable initial look-back.
LocalSchedulingClient(Duration messageExpiration, Duration initialPositionLag)	Creates a local scheduling client 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.
InMemoryScheduleStore	getMessageStore()	Returns the associated MessageStore instance.
void	setClock(Clock clock)

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

LocalSchedulingClient

public LocalSchedulingClient(Duration messageExpiration,
 Duration initialPositionLag)

Creates a local scheduling client with a configurable look-back for consumers without a stored position.

Parameters:

messageExpiration - retention duration for local schedules

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

LocalSchedulingClient

public LocalSchedulingClient(Duration messageExpiration,
 Clock clock)

LocalSchedulingClient

public LocalSchedulingClient(Duration messageExpiration,
 Clock clock,
 Duration initialPositionLag)

Creates a clock-controlled local scheduling client with a configurable initial look-back.

Parameters:

messageExpiration - retention duration for local schedules

clock - clock used by the schedule store

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

Method Details

setClock

public void setClock(Clock clock)

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