Class HandleCustomFilter

java.lang.Object

io.fluxzero.sdk.tracking.handling.HandleCustomFilter

public class HandleCustomFilter
extends Object

A MessageFilter implementation that filters DeserializingMessage instances based on a custom topic defined in the HandleCustom annotation on handler methods.

This filter ensures that a message is only routed to handler methods annotated with @HandleCustom if the topic of the message matches the value defined in the annotation.

See Also:

• HandleCustom
• DeserializingMessage

Field Summary

Fields

Modifier and Type	Field	Description
static final io.fluxzero.common.handling.MessageFilter<Object>	ALLOW_ALL

Constructor Summary

Constructors

Constructor	Description
HandleCustomFilter()

Method Summary

Modifier and Type	Method	Description
default io.fluxzero.common.handling.MessageFilter<DeserializingMessage>	and(@NonNull io.fluxzero.common.handling.MessageFilter<? super DeserializingMessage> arg0)
default Optional<Class<?>>	getLeastSpecificAllowedClass(Executable arg0, Class<? extends Annotation> arg1)
default boolean	isAlwaysTrue()
default io.fluxzero.common.handling.MessageFilter<? super DeserializingMessage>	prepare(Executable arg0, Class<? extends Annotation> arg1, Class<?> arg2)
boolean	test(DeserializingMessage message, Executable executable, Class<? extends Annotation> handlerAnnotation, Class<?> targetClass)

Methods inherited from class Object

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

Field Details

ALLOW_ALL

static final io.fluxzero.common.handling.MessageFilter<Object> ALLOW_ALL

Constructor Details

HandleCustomFilter

public HandleCustomFilter()

Method Details

test

public boolean test(DeserializingMessage message,
 Executable executable,
 Class<? extends Annotation> handlerAnnotation,
 Class<?> targetClass)

isAlwaysTrue

default boolean isAlwaysTrue()

prepare

default io.fluxzero.common.handling.MessageFilter<? super DeserializingMessage> prepare(Executable arg0,
 Class<? extends Annotation> arg1,
 Class<?> arg2)

getLeastSpecificAllowedClass

default Optional<Class<?>> getLeastSpecificAllowedClass(Executable arg0,
 Class<? extends Annotation> arg1)

and

default io.fluxzero.common.handling.MessageFilter<DeserializingMessage> and(@NonNull
 @NonNull io.fluxzero.common.handling.MessageFilter<? super DeserializingMessage> arg0)