Package io.fluxcapacitor.javaclient.tracking.handling
package io.fluxcapacitor.javaclient.tracking.handling
-
ClassDescriptionDeclares how a message should be routed to a stateful handler instance (typically annotated with
Stateful
).Default implementation of theHandlerFactory
for creating message handlers based on reflection.A default implementation of theRepositoryProvider
interface that uses aConcurrentHashMap
for each repository.A default implementation of theResponseMapper
interface that simply wraps the response in aMessage
Resolves handler method parameters of typeDeserializingMessage
.AHandlerDecorator
that intercepts handler methods annotated withHandleDocument
and 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.AMessageFilter
implementation that filtersDeserializingMessage
instances based on a custom topic defined in theHandleCustom
annotation on handler methods.Marks a method or constructor as a handler for document messages within a search collection.AMessageFilter
that routesDeserializingMessage
instances 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 decoratingHandler
instances that processDeserializingMessage
objects.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 creatingHandler
instances that processDeserializingMessage
s.Intercepts individual message handling operations, enabling cross-cutting behavior around handler invocation.Implementation ofHandler
that delegates to another handler and applies aHandlerInterceptor
.Interface for registering and invoking local message handlers.Combines twoHandlerRegistry
instances 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.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 ofHandlerRegistry
that manages and dispatches local message handlers — i.e., handlers that are invoked directly in the publishing thread without involving the Flux platform.Resolves handler method parameters of typeMessage
.Resolves handler method parameters of typeMetadata
.A specializedHandler
that maintains and mutates an internal delegate instance.AMessageFilter
used 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
,HandleQuery
orHandleCustom
correctly match the response type declared by aRequest
payload.A strategy interface for converting arbitrary response objects intoMessage
instances.AMessageFilter
that 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
.AHandler
implementation for classes annotated withStateful
, responsible for resolving and invoking stateful handler instances based onAssociation
metadata.Injects the **triggering message** that caused the current message to be published or handled.Resolves parameters annotated withTrigger
by loading the original trigger message that caused the current handler method to execute.