Class ConsumerConfiguration

java.lang.Object

io.fluxzero.sdk.tracking.ConsumerConfiguration

All Implemented Interfaces:

Substitutable<ConsumerConfiguration>

public class ConsumerConfiguration
extends Object
implements Substitutable<ConsumerConfiguration>

Configuration class that defines how a message consumer behaves during message tracking and handler invocation.

ConsumerConfiguration is used to fine-tune the behavior of message consumers beyond what is possible with the Consumer annotation. It supports handler filtering, tracking concurrency, custom interceptors, and more.

Usage: Consumers can be declared programmatically using this configuration object, or generated automatically from @Consumer annotations on handler classes or packages.

See Also:

• Consumer
• FluxzeroBuilder.addConsumerConfiguration(ConsumerConfiguration, MessageType...)

Constructor Summary

Constructors

Constructor	Description
ConsumerConfiguration()

Method Summary

Modifier and Type	Method	Description
static Stream<ConsumerConfiguration>	configurations(Collection<Class<?>> handlerClasses)	Returns a stream of ConsumerConfigurations by inspecting the given handler classes and their packages.
ConsumerConfiguration	substituteProperties()	Replaces placeholders in the properties of the current resource with resolved values from application properties and returns a new instance of type T.

Methods inherited from class Object

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

Constructor Details

ConsumerConfiguration

public ConsumerConfiguration()

Method Details

substituteProperties

public ConsumerConfiguration substituteProperties()

Description copied from interface: Substitutable

Replaces placeholders in the properties of the current resource with resolved values from application properties and returns a new instance of type T.

Specified by:

substituteProperties in interface Substitutable<ConsumerConfiguration>

Returns:

a new instance of the resource with substituted properties.

configurations

public static Stream<ConsumerConfiguration> configurations(Collection<Class<?>> handlerClasses)

Returns a stream of ConsumerConfigurations by inspecting the given handler classes and their packages. Includes both class-level and package-level @Consumer annotations.