Package io.smallrye.reactive.messaging
Interface MediatorConfiguration
-
- All Known Implementing Classes:
DefaultMediatorConfiguration
public interface MediatorConfiguration
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
MediatorConfiguration.Consumption
static class
MediatorConfiguration.Production
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MediatorConfiguration.Consumption
consumption()
Acknowledgment.Strategy
getAcknowledgment()
javax.enterprise.inject.spi.Bean<?>
getBean()
boolean
getBroadcast()
List<String>
getIncoming()
Class<? extends Invoker>
getInvokerClass()
Implementation of theInvoker
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 onMerge.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()
-
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 theInvoker
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
-
-