Uses of Interface
io.fluxzero.javaclient.publishing.DispatchInterceptor

Packages that use DispatchInterceptor

Package	Description
io.fluxzero.javaclient.configuration
io.fluxzero.javaclient.modeling
io.fluxzero.javaclient.publishing
io.fluxzero.javaclient.publishing.correlation
io.fluxzero.javaclient.publishing.dataprotection
io.fluxzero.javaclient.publishing.routing
io.fluxzero.javaclient.scheduling
io.fluxzero.javaclient.tracking.handling.authentication
io.fluxzero.javaclient.web

Uses of DispatchInterceptor in io.fluxzero.javaclient.configuration

Methods in io.fluxzero.javaclient.configuration that return DispatchInterceptor

Modifier and Type	Method	Description
DispatchInterceptor	FluxzeroConfiguration.messageRoutingInterceptor()	Special interceptor used to determine routing of dispatched messages (e.g. for multitenancy).

Methods in io.fluxzero.javaclient.configuration that return types with arguments of type DispatchInterceptor

Modifier and Type	Method	Description
Map<io.fluxzero.common.MessageType,List<DispatchInterceptor>>	FluxzeroConfiguration.highPrioDispatchInterceptors()	Dispatch interceptors applied before low-priority interceptors.
Map<io.fluxzero.common.MessageType,List<DispatchInterceptor>>	FluxzeroConfiguration.lowPrioDispatchInterceptors()	Dispatch interceptors applied after high-priority interceptors.

Methods in io.fluxzero.javaclient.configuration with parameters of type DispatchInterceptor

Modifier and Type	Method	Description
DefaultFluxzero.Builder	DefaultFluxzero.Builder.addDispatchInterceptor(@NonNull DispatchInterceptor interceptor, boolean highPriority, io.fluxzero.common.MessageType... forTypes)
FluxzeroBuilder	FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, boolean highPriority, io.fluxzero.common.MessageType... forTypes)	Adds a DispatchInterceptor for specified message types with optional priority.
default FluxzeroBuilder	FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, io.fluxzero.common.MessageType... forTypes)	Adds a DispatchInterceptor that modifies or monitors message dispatch.
DefaultFluxzero.Builder	DefaultFluxzero.Builder.replaceMessageRoutingInterceptor(@NonNull DispatchInterceptor messageRoutingInterceptor)
FluxzeroBuilder	FluxzeroBuilder.replaceMessageRoutingInterceptor(DispatchInterceptor messageRoutingInterceptor)	Replaces the default routing interceptor used for message dispatch.

Method parameters in io.fluxzero.javaclient.configuration with type arguments of type DispatchInterceptor

Modifier and Type	Method	Description
protected GenericGateway	DefaultFluxzero.Builder.createRequestGateway(Client client, io.fluxzero.common.MessageType messageType, String topic, RequestHandler requestHandler, Map<io.fluxzero.common.MessageType,DispatchInterceptor> dispatchInterceptors, Map<io.fluxzero.common.MessageType,HandlerDecorator> handlerDecorators, List<io.fluxzero.common.handling.ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>,HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper)

Uses of DispatchInterceptor in io.fluxzero.javaclient.modeling

Methods in io.fluxzero.javaclient.modeling with parameters of type DispatchInterceptor

Modifier and Type	Method	Description
static <T> Entity<T>	ModifiableAggregateRoot.load(Object aggregateId, Supplier<Entity<T>> loader, boolean commitInBatch, EventPublication eventPublication, EventPublicationStrategy publicationStrategy, EntityHelper entityHelper, Serializer serializer, DispatchInterceptor dispatchInterceptor, ModifiableAggregateRoot.CommitHandler commitHandler)

Constructors in io.fluxzero.javaclient.modeling with parameters of type DispatchInterceptor

Modifier	Constructor	Description
protected	ModifiableAggregateRoot(Entity<T> delegate, boolean commitInBatch, EventPublication eventPublication, EventPublicationStrategy publicationStrategy, EntityHelper entityHelper, Serializer serializer, DispatchInterceptor dispatchInterceptor, ModifiableAggregateRoot.CommitHandler commitHandler)

Uses of DispatchInterceptor in io.fluxzero.javaclient.publishing

Classes in io.fluxzero.javaclient.publishing that implement DispatchInterceptor

Modifier and Type	Class	Description
class	AdhocDispatchInterceptor	A DispatchInterceptor that enables thread-local, dynamically scoped interceptors during message dispatch.

Fields in io.fluxzero.javaclient.publishing declared as DispatchInterceptor

Modifier and Type	Field	Description
static final DispatchInterceptor	DispatchInterceptor.noOp	No-op implementation of the DispatchInterceptor that returns the original message unchanged.

Methods in io.fluxzero.javaclient.publishing that return DispatchInterceptor

Modifier and Type	Method	Description
default DispatchInterceptor	DispatchInterceptor.andThen(DispatchInterceptor nextInterceptor)	Chains this interceptor with another.

Methods in io.fluxzero.javaclient.publishing that return types with arguments of type DispatchInterceptor

Modifier and Type	Method	Description
static Optional<? extends DispatchInterceptor>	AdhocDispatchInterceptor.getAdhocInterceptor(io.fluxzero.common.MessageType messageType)	Returns the current thread-local ad hoc interceptor for the given MessageType, if present.

Methods in io.fluxzero.javaclient.publishing with parameters of type DispatchInterceptor

Modifier and Type	Method	Description
default DispatchInterceptor	DispatchInterceptor.andThen(DispatchInterceptor nextInterceptor)	Chains this interceptor with another.
static void	AdhocDispatchInterceptor.runWithAdhocInterceptor(Runnable task, DispatchInterceptor adhocInterceptor, io.fluxzero.common.MessageType... messageTypes)	Executes the given Runnable while temporarily enabling the provided interceptor for the specified message types.
static <T> T	AdhocDispatchInterceptor.runWithAdhocInterceptor(Callable<T> task, DispatchInterceptor adhocInterceptor, io.fluxzero.common.MessageType... messageTypes)	Executes the given Callable while temporarily enabling the provided interceptor for the specified message types.

Uses of DispatchInterceptor in io.fluxzero.javaclient.publishing.correlation

Classes in io.fluxzero.javaclient.publishing.correlation that implement DispatchInterceptor

Modifier and Type	Class	Description
class	CorrelatingInterceptor	A DispatchInterceptor that enriches outgoing messages with correlation metadata, enabling full traceability across message flows within Fluxzero.

Uses of DispatchInterceptor in io.fluxzero.javaclient.publishing.dataprotection

Classes in io.fluxzero.javaclient.publishing.dataprotection that implement DispatchInterceptor

Modifier and Type	Class	Description
class	DataProtectionInterceptor	A DispatchInterceptor and HandlerInterceptor that supports secure transmission of sensitive data fields by removing them from the payload before dispatch and restoring them during handling.

Uses of DispatchInterceptor in io.fluxzero.javaclient.publishing.routing

Classes in io.fluxzero.javaclient.publishing.routing that implement DispatchInterceptor

Modifier and Type	Class	Description
class	MessageRoutingInterceptor	A DispatchInterceptor that assigns a routing segment to messages prior to dispatch.

Uses of DispatchInterceptor in io.fluxzero.javaclient.scheduling

Classes in io.fluxzero.javaclient.scheduling that implement DispatchInterceptor

Modifier and Type	Class	Description
class	SchedulingInterceptor	Intercepts scheduled messages to handle periodic scheduling logic.

Uses of DispatchInterceptor in io.fluxzero.javaclient.tracking.handling.authentication

Classes in io.fluxzero.javaclient.tracking.handling.authentication that implement DispatchInterceptor

Modifier and Type	Class	Description
class	AuthenticatingInterceptor

Uses of DispatchInterceptor in io.fluxzero.javaclient.web

Classes in io.fluxzero.javaclient.web that implement DispatchInterceptor

Modifier and Type	Class	Description
class	WebResponseCompressingInterceptor	A DispatchInterceptor that applies GZIP compression to outgoing WebResponse messages based on request headers and response size.
class	WebsocketResponseInterceptor	A DispatchInterceptor that modifies outgoing WebResponse messages in response to WebSocket-based WebRequests.