Uses of Interface
io.fluxcapacitor.javaclient.publishing.DispatchInterceptor
Packages that use DispatchInterceptor
Package
Description
-
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.configuration
Methods in io.fluxcapacitor.javaclient.configuration that return DispatchInterceptorModifier and TypeMethodDescriptionFluxCapacitorConfiguration.messageRoutingInterceptor()
Special interceptor used to determine routing of dispatched messages (e.g. for multitenancy).Methods in io.fluxcapacitor.javaclient.configuration that return types with arguments of type DispatchInterceptorModifier and TypeMethodDescriptionFluxCapacitorConfiguration.highPrioDispatchInterceptors()
Dispatch interceptors applied before low-priority interceptors.FluxCapacitorConfiguration.lowPrioDispatchInterceptors()
Dispatch interceptors applied after high-priority interceptors.Methods in io.fluxcapacitor.javaclient.configuration with parameters of type DispatchInterceptorModifier and TypeMethodDescriptionDefaultFluxCapacitor.Builder.addDispatchInterceptor
(@NonNull DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes) FluxCapacitorBuilder.addDispatchInterceptor
(DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes) Adds aDispatchInterceptor
for specified message types with optional priority.default FluxCapacitorBuilder
FluxCapacitorBuilder.addDispatchInterceptor
(DispatchInterceptor interceptor, MessageType... forTypes) Adds aDispatchInterceptor
that modifies or monitors message dispatch.DefaultFluxCapacitor.Builder.replaceMessageRoutingInterceptor
(@NonNull DispatchInterceptor messageRoutingInterceptor) FluxCapacitorBuilder.replaceMessageRoutingInterceptor
(DispatchInterceptor messageRoutingInterceptor) Replaces the default routing interceptor used for message dispatch.Method parameters in io.fluxcapacitor.javaclient.configuration with type arguments of type DispatchInterceptorModifier and TypeMethodDescriptionprotected GenericGateway
DefaultFluxCapacitor.Builder.createRequestGateway
(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper) -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.modeling
Methods in io.fluxcapacitor.javaclient.modeling with parameters of type DispatchInterceptorModifier and TypeMethodDescriptionstatic <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.fluxcapacitor.javaclient.modeling with parameters of type DispatchInterceptorModifierConstructorDescriptionprotected
ModifiableAggregateRoot
(Entity<T> delegate, boolean commitInBatch, EventPublication eventPublication, EventPublicationStrategy publicationStrategy, EntityHelper entityHelper, Serializer serializer, DispatchInterceptor dispatchInterceptor, ModifiableAggregateRoot.CommitHandler commitHandler) -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.publishing
Classes in io.fluxcapacitor.javaclient.publishing that implement DispatchInterceptorModifier and TypeClassDescriptionclass
ADispatchInterceptor
that enables thread-local, dynamically scoped interceptors during message dispatch.Fields in io.fluxcapacitor.javaclient.publishing declared as DispatchInterceptorModifier and TypeFieldDescriptionstatic final DispatchInterceptor
DispatchInterceptor.noOp
No-op implementation of theDispatchInterceptor
that returns the original message unchanged.Methods in io.fluxcapacitor.javaclient.publishing that return DispatchInterceptorModifier and TypeMethodDescriptiondefault DispatchInterceptor
DispatchInterceptor.andThen
(DispatchInterceptor nextInterceptor) Chains this interceptor with another.Methods in io.fluxcapacitor.javaclient.publishing that return types with arguments of type DispatchInterceptorModifier and TypeMethodDescriptionstatic Optional
<? extends DispatchInterceptor> AdhocDispatchInterceptor.getAdhocInterceptor
(MessageType messageType) Returns the current thread-local ad hoc interceptor for the givenMessageType
, if present.Methods in io.fluxcapacitor.javaclient.publishing with parameters of type DispatchInterceptorModifier and TypeMethodDescriptiondefault DispatchInterceptor
DispatchInterceptor.andThen
(DispatchInterceptor nextInterceptor) Chains this interceptor with another.static void
AdhocDispatchInterceptor.runWithAdhocInterceptor
(Runnable task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes) Executes the givenRunnable
while temporarily enabling the provided interceptor for the specified message types.static <T> T
AdhocDispatchInterceptor.runWithAdhocInterceptor
(Callable<T> task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes) Executes the givenCallable
while temporarily enabling the provided interceptor for the specified message types. -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.publishing.correlation
Classes in io.fluxcapacitor.javaclient.publishing.correlation that implement DispatchInterceptorModifier and TypeClassDescriptionclass
ADispatchInterceptor
that enriches outgoing messages with correlation metadata, enabling full traceability across message flows within Flux Capacitor. -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.publishing.dataprotection
Classes in io.fluxcapacitor.javaclient.publishing.dataprotection that implement DispatchInterceptorModifier and TypeClassDescriptionclass
ADispatchInterceptor
andHandlerInterceptor
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.fluxcapacitor.javaclient.publishing.routing
Classes in io.fluxcapacitor.javaclient.publishing.routing that implement DispatchInterceptorModifier and TypeClassDescriptionclass
ADispatchInterceptor
that assigns a routing segment to messages prior to dispatch. -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.scheduling
Classes in io.fluxcapacitor.javaclient.scheduling that implement DispatchInterceptorModifier and TypeClassDescriptionclass
Intercepts scheduled messages to handle periodic scheduling logic. -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.tracking.handling.authentication
Classes in io.fluxcapacitor.javaclient.tracking.handling.authentication that implement DispatchInterceptor -
Uses of DispatchInterceptor in io.fluxcapacitor.javaclient.web
Classes in io.fluxcapacitor.javaclient.web that implement DispatchInterceptorModifier and TypeClassDescriptionclass
ADispatchInterceptor
that applies GZIP compression to outgoingWebResponse
messages based on request headers and response size.class
ADispatchInterceptor
that modifies outgoingWebResponse
messages in response to WebSocket-basedWebRequest
s.