Package io.fluxzero.sdk.tracking.handling
package io.fluxzero.sdk.tracking.handling
-
ClassDescriptionDeclares how a message should be routed to a stateful handler instance (typically annotated with
Stateful).Default implementation of theHandlerFactoryfor creating message handlers based on reflection.A default implementation of theRepositoryProviderinterface that uses aConcurrentHashMapfor each repository.A default implementation of theResponseMapperinterface that simply wraps the response in aMessageAHandlerDecoratorthat intercepts handler methods annotated withHandleDocumentand synchronizes their return values with aDocumentStore.Marks a method or constructor as a handler for command messages (MessageType.COMMAND).Marks a method or constructor as a handler for messages from a custom message topic.AMessageFilterimplementation that filtersDeserializingMessageinstances based on a custom topic defined in theHandleCustomannotation on handler methods.Marks a method or constructor as a handler for document messages within a search collection.AMessageFilterthat routesDeserializingMessageinstances to methods annotated withHandleDocument, based on the message's topic.Marks a method or constructor as a handler for error messages (MessageType.ERROR).Marks a method or constructor as an event handler for incoming messages of typeMessageType.EVENT.Meta-annotation used to declare that an annotation marks a method as a message handler for a specificMessageType.Marks a method or constructor as a handler for internal metrics events (MessageType.METRICS).Marks a method or constructor as a handler for notification messages (MessageType.NOTIFICATION).Marks a method or constructor as a handler for query messages (MessageType.QUERY).Functional interface for decoratingHandlerinstances that processDeserializingMessageobjects.A composite decorator that merges two decorators into one.Marks a method or constructor as a handler for result messages (MessageType.RESULT).Factory interface for creatingHandlerinstances that processDeserializingMessages.Intercepts individual message handling operations, enabling cross-cutting behavior around handler invocation.Implementation ofHandlerthat delegates to another handler and applies aHandlerInterceptor.Interface for registering and invoking local message handlers.Combines twoHandlerRegistryinstances into one.A no-op handler registry that performs no registration or dispatch.Marks a method or constructor as a handler for scheduled messages (MessageType.SCHEDULE).Base interface for gateways that support registering local message handlers.Thrown to indicate that a command was rejected due to business logic violations.Resolves handler method parameters by simply injecting the input if the parameter type is assignable from the input type.Tracks the lifecycle and identity of a single message handler invocation.AParameterResolverthat converts the message payload to the parameter's declared type if that type is assignable toJsonNode.Marks a message handler method, class, or package as a **local handler**—one that is invoked immediately in the publishing thread rather than asynchronously through tracking.In-memory implementation ofHandlerRegistrythat manages and dispatches local message handlers — i.e., handlers that are invoked directly in the publishing thread without involving the Fluxzero Runtime.Resolves handler method parameters of typeDeserializingMessage.Resolves handler method parameters of typeMetadata.A specializedHandlerthat maintains and mutates an internal delegate instance.AMessageFilterused to restrict message handling based on the payload type.Resolves handler method parameters by injecting the message payload.Provides access to a singleton-style repository for a given class type.Request<R>Marker interface for request messages (e.g., commands or queries) that expect a response of a specific type.Annotation processor that validates whether handler methods annotated withHandleCommand,HandleQueryorHandleCustomcorrectly match the response type declared by aRequestpayload.A strategy interface for converting arbitrary response objects intoMessageinstances.AMessageFilterthat restricts handler invocation based on segment membership, using routing keys.Declares that a class is a stateful message handler — i.e., one whose state is persisted and which can receive messages viaAssociation.AHandlerimplementation for classes annotated withStateful, responsible for resolving and invoking stateful handler instances based onAssociationmetadata.Injects the **triggering message** that caused the current message to be published or handled.Resolves parameters annotated withTriggerby loading the original trigger message that caused the current handler method to execute.