Class MessageParameterResolver

java.lang.Object

io.fluxzero.sdk.tracking.handling.MessageParameterResolver

public class MessageParameterResolver
extends Object

Resolves handler method parameters of type DeserializingMessage.

This allows handler methods to access the deserialization context, including message metadata, payload, and raw serialized content.

Useful when advanced information about the message is needed, such as the Fluxzero-assigned message index.

Constructor Summary

Constructors

Constructor	Description
MessageParameterResolver()

Method Summary

Modifier and Type	Method	Description
default boolean	determinesSpecificity()
Object	getInputCacheKey(Parameter parameter, Annotation methodAnnotation, io.fluxzero.common.handling.HandlerInput<Object> representative)
boolean	isNoMatchPayloadClassKey(Parameter parameter, Annotation methodAnnotation, io.fluxzero.common.handling.HandlerInput<Object> representative)
boolean	isPayloadClassKey(Parameter parameter, Annotation methodAnnotation, io.fluxzero.common.handling.HandlerInput<Object> representative)
boolean	matches(Parameter parameter, Annotation methodAnnotation, Object value)
boolean	mayApply(Executable method, Class<?> targetClass)
Function<Object,Object>	prepare(Parameter parameter, Annotation methodAnnotation)
io.fluxzero.common.handling.HandlerInputResolver.Resolution<Object>	prepareInput(Parameter parameter, Annotation methodAnnotation, io.fluxzero.common.handling.HandlerInput<Object> representative)
Function<Object,Object>	resolve(Parameter p, Annotation methodAnnotation)
Function<Object,Object>	resolveIfPossible(Parameter parameter, Annotation methodAnnotation, Object value)
default int	specificityPriority()
default boolean	test(Object arg0, Parameter arg1)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MessageParameterResolver

public MessageParameterResolver()

Method Details

resolve

public Function<Object,Object> resolve(Parameter p,
 Annotation methodAnnotation)

prepare

public Function<Object,Object> prepare(Parameter parameter,
 Annotation methodAnnotation)

resolveIfPossible

public Function<Object,Object> resolveIfPossible(Parameter parameter,
 Annotation methodAnnotation,
 Object value)

matches

public boolean matches(Parameter parameter,
 Annotation methodAnnotation,
 Object value)

mayApply

public boolean mayApply(Executable method,
 Class<?> targetClass)

getInputCacheKey

public Object getInputCacheKey(Parameter parameter,
 Annotation methodAnnotation,
 io.fluxzero.common.handling.HandlerInput<Object> representative)

isPayloadClassKey

public boolean isPayloadClassKey(Parameter parameter,
 Annotation methodAnnotation,
 io.fluxzero.common.handling.HandlerInput<Object> representative)

isNoMatchPayloadClassKey

public boolean isNoMatchPayloadClassKey(Parameter parameter,
 Annotation methodAnnotation,
 io.fluxzero.common.handling.HandlerInput<Object> representative)

prepareInput

public io.fluxzero.common.handling.HandlerInputResolver.Resolution<Object> prepareInput(Parameter parameter,
 Annotation methodAnnotation,
 io.fluxzero.common.handling.HandlerInput<Object> representative)

determinesSpecificity

default boolean determinesSpecificity()

specificityPriority

default int specificityPriority()

test

default boolean test(Object arg0,
 Parameter arg1)