io.smallrye.reactive.messaging

Interface MediatorConfiguration

All Known Implementing Classes:

DefaultMediatorConfiguration

public interface MediatorConfiguration

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	MediatorConfiguration.Consumption
static class	MediatorConfiguration.Production

Method Summary

Modifier and Type	Method and Description
MediatorConfiguration.Consumption	consumption()
Acknowledgment.Strategy	getAcknowledgment()
javax.enterprise.inject.spi.Bean<?>	getBean()
boolean	getBroadcast()
List<String>	getIncoming()
Type	getIngestedPayloadType()
Class<? extends Invoker>	getInvokerClass() Implementation of the Invoker interface that can be used to invoke the method described by this configuration The invoker class can either have a no-arg constructor in which case it's expected to be look up the bean programmatically, or have a constructor that takes a single Object parameter - the bean to operate on
Merge.Mode	getMerge()
Method	getMethod()
int	getNumberOfSubscriberBeforeConnecting()
String	getOutgoing()
Class<?>[]	getParameterTypes()
Class<?>	getReturnType()
String	getWorkerPoolName()
boolean	isBlocking()
boolean	isBlockingExecutionOrdered()
String	methodAsString()
MediatorConfiguration.Production	production()
Shape	shape()
boolean	usesBuilderTypes()

Method Detail

shape

Shape shape()

getOutgoing

String getOutgoing()

getIncoming

List<String> getIncoming()

methodAsString

String methodAsString()

getMethod

Method getMethod()

getReturnType

Class<?> getReturnType()

getParameterTypes

Class<?>[] getParameterTypes()

consumption

MediatorConfiguration.Consumption consumption()

production

MediatorConfiguration.Production production()

usesBuilderTypes

boolean usesBuilderTypes()

getAcknowledgment

Acknowledgment.Strategy getAcknowledgment()

getMerge

Merge.Mode getMerge()

getBroadcast

boolean getBroadcast()

getBean

javax.enterprise.inject.spi.Bean<?> getBean()

getNumberOfSubscriberBeforeConnecting

int getNumberOfSubscriberBeforeConnecting()

isBlocking

boolean isBlocking()

getWorkerPoolName

String getWorkerPoolName()

isBlockingExecutionOrdered

boolean isBlockingExecutionOrdered()

getInvokerClass

Class<? extends Invoker> getInvokerClass()

Implementation of the Invoker interface that can be used to invoke the method described by this configuration The invoker class can either have a no-arg constructor in which case it's expected to be look up the bean programmatically, or have a constructor that takes a single Object parameter - the bean to operate on

getIngestedPayloadType

Type getIngestedPayloadType()

Returns:

the discovered ingested payload type. May be null if there is no consumption or the type cannot be extracted. Conversion is based on this type.