Uses of Interface
io.fluxzero.sdk.common.HasMessage
Packages that use HasMessage
Package
Description
-
Uses of HasMessage in io.fluxzero.sdk.common
Classes in io.fluxzero.sdk.common that implement HasMessageModifier and TypeClassDescriptionclassRepresents a unit of communication within the Fluxzero Runtime, wrapping a payload and its metadata.Methods in io.fluxzero.sdk.common with parameters of type HasMessageModifier and TypeMethodDescriptionstatic booleanClientUtils.isLocalHandler(HandlerInvoker invoker, HasMessage message) Determines if the specified handler method handles messages locally.static booleanClientUtils.isLocalSelfHandler(HandlerInvoker invoker, HasMessage message) Returns whether the handler method should only handle messages from the same instance ("self"). -
Uses of HasMessage in io.fluxzero.sdk.common.serialization
Classes in io.fluxzero.sdk.common.serialization that implement HasMessageModifier and TypeClassDescriptionclassWrapper for aMessagethat supports lazy deserialization, context caching, type adaptation, and batch-level execution utilities. -
Uses of HasMessage in io.fluxzero.sdk.modeling
Classes in io.fluxzero.sdk.modeling that implement HasMessageModifier and TypeClassDescriptionprotected static classDecorates aDeserializingMessagewith an associated entity.protected static classWraps a message and its corresponding entity for use in interception or handler invocation. -
Uses of HasMessage in io.fluxzero.sdk.scheduling
Classes in io.fluxzero.sdk.scheduling that implement HasMessageModifier and TypeClassDescriptionclassRepresents a scheduled message to be delivered at a specific future time. -
Uses of HasMessage in io.fluxzero.sdk.tracking.handling
Classes in io.fluxzero.sdk.tracking.handling that implement interfaces with type arguments of type HasMessageModifier and TypeClassDescriptionclassAMessageFilterused to restrict message handling based on the payload type.classResolves handler method parameters by injecting the message payload.classAMessageFilterthat restricts handler invocation based on segment membership, using routing keys.classResolves parameters annotated withTriggerby loading the original trigger message that caused the current handler method to execute.classResolves parameters annotated withTriggerby loading the original trigger message that caused the current handler method to execute.Methods in io.fluxzero.sdk.tracking.handling that return types with arguments of type HasMessageModifier and TypeMethodDescriptionPayloadParameterResolver.resolve(Parameter p, Annotation methodAnnotation) TriggerParameterResolver.resolve(Parameter p, Annotation methodAnnotation) Resolves the value to inject into a parameter annotated withTrigger.Methods in io.fluxzero.sdk.tracking.handling with parameters of type HasMessageModifier and TypeMethodDescriptionprotected booleanTriggerParameterResolver.filterMessage(HasMessage message, Trigger trigger) TriggerParameterResolver.getConsumer(HasMessage message) TriggerParameterResolver.getTriggerClass(HasMessage message) protected Optional<MessageType> TriggerParameterResolver.getTriggerMessageType(HasMessage message) booleanPayloadParameterResolver.matches(Parameter p, Annotation methodAnnotation, HasMessage value) booleanTriggerParameterResolver.matches(Parameter parameter, Annotation methodAnnotation, HasMessage value) Checks if the given method parameter should be resolved by this resolver.booleanPayloadFilter.test(HasMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation) booleanPayloadParameterResolver.test(HasMessage message, Parameter parameter) booleanSegmentFilter.test(HasMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation) booleanTriggerParameterResolver.test(HasMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation) Evaluates whether the given message should be accepted by the handler method based on the associatedTriggerannotation.booleanTriggerParameterResolver.test(HasMessage message, Parameter parameter) Applies additional filtering logic based on theTriggerannotation on the parameter. -
Uses of HasMessage in io.fluxzero.sdk.tracking.handling.authentication
Methods in io.fluxzero.sdk.tracking.handling.authentication with parameters of type HasMessageModifier and TypeMethodDescriptionAbstractUserProvider.fromMessage(HasMessage message) Extracts aUserfrom the metadata of a message.DelegatingUserProvider.fromMessage(HasMessage message) NoOpUserProvider.fromMessage(HasMessage message) UserProvider.fromMessage(HasMessage message) Extracts theUserfrom a givenHasMessageinstance. -
Uses of HasMessage in io.fluxzero.sdk.tracking.metrics
Methods in io.fluxzero.sdk.tracking.metrics with parameters of type HasMessageModifier and TypeMethodDescriptionprotected booleanHandlerMonitor.logMetrics(HandlerInvoker invoker, HasMessage message) -
Uses of HasMessage in io.fluxzero.sdk.web
Classes in io.fluxzero.sdk.web that implement HasMessageModifier and TypeClassDescriptionclassRepresents a web request message within the Fluxzero Runtime.classRepresents a response to aWebRequestin the Fluxzero Runtime.Classes in io.fluxzero.sdk.web that implement interfaces with type arguments of type HasMessageModifier and TypeClassDescriptionclassResolves method parameters in web handler methods based on meta-annotations derived fromWebParam.classResolves a method parameter from the payload of aWebRequest.classDecorator that adds WebSocket session support to handler classes and enables parameter injection forSocketSession.Methods in io.fluxzero.sdk.web that return types with arguments of type HasMessageModifier and TypeMethodDescriptionWebParamParameterResolver.resolve(Parameter p, Annotation methodAnnotation) Resolves the parameter value from aWebRequestContextusing the metadata provided by a parameter annotation that is meta-annotated withWebParam.WebPayloadParameterResolver.resolve(Parameter p, Annotation methodAnnotation) Resolves the value for the given method parameter by converting the message payload to the expected parameter type.WebsocketHandlerDecorator.resolve(Parameter p, Annotation methodAnnotation) Resolves aSocketSessionparameter from the currentHasMessagecontext.Methods in io.fluxzero.sdk.web with parameters of type HasMessageModifier and TypeMethodDescriptionprotected DefaultSocketSessionWebsocketHandlerDecorator.getOrCreateSocketSession(HasMessage m) booleanWebParamParameterResolver.matches(Parameter parameter, Annotation methodAnnotation, HasMessage value) Determines if this resolver is applicable to a given method parameter.booleanWebPayloadParameterResolver.matches(Parameter parameter, Annotation methodAnnotation, HasMessage value) Determines whether this resolver should be used for the given method parameter.booleanWebsocketHandlerDecorator.matches(Parameter parameter, Annotation methodAnnotation, HasMessage value) Determines whether this resolver supports injecting aSocketSessionfor the given method parameter.booleanWebPayloadParameterResolver.test(HasMessage m, Parameter p)