Uses of Interface
io.fluxzero.sdk.publishing.DispatchInterceptor
Packages that use DispatchInterceptor
Package
Description
-
Uses of DispatchInterceptor in io.fluxzero.sdk.configuration
Methods in io.fluxzero.sdk.configuration that return DispatchInterceptorModifier and TypeMethodDescriptionFluxzeroConfiguration.messageRoutingInterceptor()Special interceptor used to determine routing of dispatched messages (e.g. for multitenancy).Methods in io.fluxzero.sdk.configuration that return types with arguments of type DispatchInterceptorModifier and TypeMethodDescriptionFluxzeroConfiguration.highPrioDispatchInterceptors()Dispatch interceptors applied before low-priority interceptors.FluxzeroConfiguration.lowPrioDispatchInterceptors()Dispatch interceptors applied after high-priority interceptors.Methods in io.fluxzero.sdk.configuration with parameters of type DispatchInterceptorModifier and TypeMethodDescriptionDefaultFluxzero.Builder.addDispatchInterceptor(@NonNull DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes) FluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, boolean highPriority, MessageType... forTypes) Adds aDispatchInterceptorfor specified message types with optional priority.default FluxzeroBuilderFluxzeroBuilder.addDispatchInterceptor(DispatchInterceptor interceptor, MessageType... forTypes) Adds aDispatchInterceptorthat modifies or monitors message dispatch.DefaultFluxzero.Builder.replaceMessageRoutingInterceptor(@NonNull DispatchInterceptor messageRoutingInterceptor) FluxzeroBuilder.replaceMessageRoutingInterceptor(DispatchInterceptor messageRoutingInterceptor) Replaces the default routing interceptor used for message dispatch.Method parameters in io.fluxzero.sdk.configuration with type arguments of type DispatchInterceptorModifier and TypeMethodDescriptionprotected GenericGatewayDefaultFluxzero.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.fluxzero.sdk.modeling
Methods in io.fluxzero.sdk.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.fluxzero.sdk.modeling with parameters of type DispatchInterceptorModifierConstructorDescriptionprotectedModifiableAggregateRoot(Entity<T> delegate, boolean commitInBatch, EventPublication eventPublication, EventPublicationStrategy publicationStrategy, EntityHelper entityHelper, Serializer serializer, DispatchInterceptor dispatchInterceptor, ModifiableAggregateRoot.CommitHandler commitHandler) -
Uses of DispatchInterceptor in io.fluxzero.sdk.publishing
Classes in io.fluxzero.sdk.publishing that implement DispatchInterceptorModifier and TypeClassDescriptionclassADispatchInterceptorthat enables thread-local, dynamically scoped interceptors during message dispatch.Fields in io.fluxzero.sdk.publishing declared as DispatchInterceptorModifier and TypeFieldDescriptionstatic final DispatchInterceptorDispatchInterceptor.noOpNo-op implementation of theDispatchInterceptorthat returns the original message unchanged.Methods in io.fluxzero.sdk.publishing that return DispatchInterceptorModifier and TypeMethodDescriptiondefault DispatchInterceptorDispatchInterceptor.andThen(DispatchInterceptor nextInterceptor) Chains this interceptor with another.Methods in io.fluxzero.sdk.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.fluxzero.sdk.publishing with parameters of type DispatchInterceptorModifier and TypeMethodDescriptiondefault DispatchInterceptorDispatchInterceptor.andThen(DispatchInterceptor nextInterceptor) Chains this interceptor with another.static voidAdhocDispatchInterceptor.runWithAdhocInterceptor(Runnable task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes) Executes the givenRunnablewhile temporarily enabling the provided interceptor for the specified message types.static <T> TAdhocDispatchInterceptor.runWithAdhocInterceptor(Callable<T> task, DispatchInterceptor adhocInterceptor, MessageType... messageTypes) Executes the givenCallablewhile temporarily enabling the provided interceptor for the specified message types. -
Uses of DispatchInterceptor in io.fluxzero.sdk.publishing.correlation
Classes in io.fluxzero.sdk.publishing.correlation that implement DispatchInterceptorModifier and TypeClassDescriptionclassADispatchInterceptorthat enriches outgoing messages with correlation metadata, enabling full traceability across message flows within Fluxzero. -
Uses of DispatchInterceptor in io.fluxzero.sdk.publishing.dataprotection
Classes in io.fluxzero.sdk.publishing.dataprotection that implement DispatchInterceptorModifier and TypeClassDescriptionclassADispatchInterceptorandHandlerInterceptorthat 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.sdk.publishing.routing
Classes in io.fluxzero.sdk.publishing.routing that implement DispatchInterceptorModifier and TypeClassDescriptionclassADispatchInterceptorthat assigns a routing segment to messages prior to dispatch. -
Uses of DispatchInterceptor in io.fluxzero.sdk.scheduling
Classes in io.fluxzero.sdk.scheduling that implement DispatchInterceptorModifier and TypeClassDescriptionclassIntercepts scheduled messages to handle periodic scheduling logic. -
Uses of DispatchInterceptor in io.fluxzero.sdk.tracking.handling.authentication
Classes in io.fluxzero.sdk.tracking.handling.authentication that implement DispatchInterceptor -
Uses of DispatchInterceptor in io.fluxzero.sdk.web
Classes in io.fluxzero.sdk.web that implement DispatchInterceptorModifier and TypeClassDescriptionclassADispatchInterceptorthat applies GZIP compression to outgoingWebResponsemessages based on request headers and response size.classADispatchInterceptorthat modifies outgoingWebResponsemessages in response to WebSocket-basedWebRequests.