Package io.smallrye.reactive.messaging.extension

Class MediatorManager

java.lang.Object

io.smallrye.reactive.messaging.extension.MediatorManager

@ApplicationScoped
public class MediatorManager
extends Object

Class responsible for managing mediators

Field Summary

Fields

Modifier and Type	Field	Description
static String	STRICT_MODE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
MediatorManager()

Method Summary

Modifier and Type	Method	Description
void	addAnalyzed(Collection<? extends MediatorConfiguration> mediators)
<T> void	analyze(Class<?> beanClass, javax.enterprise.inject.spi.Bean<T> bean)
<T> void	analyze(javax.enterprise.inject.spi.AnnotatedType<T> annotatedType, javax.enterprise.inject.spi.Bean<T> bean)
void	initializeAndRun()
void	initializeEmitter(String name, String overFlowStrategy, long bufferSize, long defaultBufferSize)
void	initializeEmitters(Map<String,OnOverflow> emitters)
boolean	isInitialized()

Methods inherited from class java.lang.Object

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

Field Detail

STRICT_MODE_PROPERTY

public static final String STRICT_MODE_PROPERTY

See Also:

Constant Field Values

Constructor Detail

MediatorManager

public MediatorManager()

Method Detail

isInitialized

public boolean isInitialized()

analyze

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

analyze

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

addAnalyzed

public void addAnalyzed(Collection<? extends MediatorConfiguration> mediators)

initializeAndRun

public void initializeAndRun()

initializeEmitters

public void initializeEmitters(Map<String,OnOverflow> emitters)

initializeEmitter

public void initializeEmitter(String name,
                              String overFlowStrategy,
                              long bufferSize,
                              long defaultBufferSize)