Package io.fluxzero.sdk.publishing
package io.fluxzero.sdk.publishing
-
ClassDescriptionA
DispatchInterceptorthat enables thread-local, dynamically scoped interceptors during message dispatch.Gateway interface for publishing command messages in Fluxzero.Default implementation of theCommandGatewayinterface.Default implementation of theErrorGatewayinterface.Default implementation of theEventGatewayinterface.Default implementation of theMetricsGatewayinterface.Default implementation of theQueryGatewayinterface.Default implementation of theRequestHandlerinterface.Default implementation of theResultGatewayinterface for sending response messages.Mechanism that enables modification, monitoring, or conditional suppression of messages before they are dispatched to local handlers or published to the Fluxzero Runtime.Gateway interface for reporting errors during message handling.Gateway for publishing event messages to Fluxzero.A generic message gateway for publication of messages in Fluxzero.Gateway interface for publishing metrics messages in Fluxzero.Gateway interface for dispatching queries and receiving responses in Fluxzero.Thrown when a message publication chain exceeds the configured maximum depth.Prevents runaway recursive publication loops by carrying a publication depth in message metadata.Handles the lifecycle of request/response interactions in a Fluxzero client.Gateway interface for sending result messages in response to a command or query.Annotation to be placed on requests (i.e. queries and commands).Gateway for sending outbound web requests via Fluxzero’s proxy mechanism.