Class ScheduledCommandHandler

java.lang.Object
io.fluxzero.sdk.scheduling.ScheduledCommandHandler
@Consumer(name="ScheduledCommandHandler", typeFilter="\\Qio.fluxzero.sdk.scheduling.ScheduledCommand\\E") public class ScheduledCommandHandler extends Object
Internal handler responsible for executing scheduled commands when they are due. Typically, these commands have been scheduled using Fluxzero.scheduleCommand(Object, Instant) methods or via the MessageScheduler.

This component listens to Schedule messages containing serialized command payloads wrapped in ScheduledCommand. When a scheduled time is reached, the handler triggers the dispatch of the command. The handler attempts to deserialize and dispatch the command using the standard Fluxzero command gateway.

Deserialization is attempted prior to dispatch to ensure that any configured dispatch interceptors are invoked. Many interceptors (e.g. those for correlation, routing, data protection, or metrics) require access to the command payload and metadata, and therefore rely on a proper DeserializingMessage context.

If deserialization fails (e.g. due to an unknown type or missing class), the command is appended directly to the lower level command gateway client using a raw SerializedMessage.

Consumers typically do not invoke or register this handler directly. It is automatically configured in the Fluxzero client unless explicitly disabled using FluxzeroBuilder.disableScheduledCommandHandler().

See Also:

  • Constructor Details

    • ScheduledCommandHandler

      public ScheduledCommandHandler()