Package io.smallrye.reactive.messaging.providers.extension

Class MediatorManager

java.lang.Object

io.smallrye.reactive.messaging.providers.extension.MediatorManager

@ApplicationScoped
public class MediatorManager
extends Object

Class responsible for creating mediators instances and starting the management.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STRICT_MODE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
MediatorManager()

Method Summary

Modifier and Type	Method	Description
void	addAnalyzed(Collection<? extends io.smallrye.reactive.messaging.MediatorConfiguration> mediators)
void	addChannel(ChannelConfiguration channel)
void	addEmitter(io.smallrye.reactive.messaging.EmitterConfiguration emitterConfiguration)
<T> void	analyze(jakarta.enterprise.inject.spi.AnnotatedType<T> annotatedType, jakarta.enterprise.inject.spi.Bean<T> bean)
<T> void	analyze(Class<?> beanClass, jakarta.enterprise.inject.spi.Bean<T> bean)	This method is used in the Quarkus extension.
AbstractMediator	createMediator(io.smallrye.reactive.messaging.MediatorConfiguration configuration)
Optional<Integer>	getChannelConcurrency(String incoming)
Map<String,Integer>	getIncomingConcurrency(io.smallrye.reactive.messaging.MediatorConfiguration configuration)
void	start()

Methods inherited from class java.lang.Object

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

Field Details

STRICT_MODE_PROPERTY

public static final String STRICT_MODE_PROPERTY

See Also:

• Constant Field Values

Constructor Details

MediatorManager

public MediatorManager()

Method Details

analyze

public <T> void analyze(jakarta.enterprise.inject.spi.AnnotatedType<T> annotatedType,
 jakarta.enterprise.inject.spi.Bean<T> bean)

getIncomingConcurrency

public Map<String,Integer> getIncomingConcurrency(io.smallrye.reactive.messaging.MediatorConfiguration configuration)

getChannelConcurrency

public Optional<Integer> getChannelConcurrency(String incoming)

analyze

public <T> void analyze(Class<?> beanClass,
 jakarta.enterprise.inject.spi.Bean<T> bean)

This method is used in the Quarkus extension.

Type Parameters:

T - the type.

Parameters:

beanClass - the bean class

bean - the bean instance

addAnalyzed

public void addAnalyzed(Collection<? extends io.smallrye.reactive.messaging.MediatorConfiguration> mediators)

addEmitter

public void addEmitter(io.smallrye.reactive.messaging.EmitterConfiguration emitterConfiguration)

addChannel

public void addChannel(ChannelConfiguration channel)

createMediator

public AbstractMediator createMediator(io.smallrye.reactive.messaging.MediatorConfiguration configuration)

start

public void start()