Package io.smallrye.reactive.messaging

Class DefaultMediatorConfiguration

java.lang.Object

io.smallrye.reactive.messaging.DefaultMediatorConfiguration

All Implemented Interfaces:

MediatorConfiguration

public class DefaultMediatorConfiguration
extends Object
implements MediatorConfiguration

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	DefaultMediatorConfiguration.AlwaysInvalidIndexGenericTypeAssignable
protected static class	DefaultMediatorConfiguration.MethodParamGenericTypeAssignable
protected static class	DefaultMediatorConfiguration.ReturnTypeGenericTypeAssignable

Nested classes/interfaces inherited from interface io.smallrye.reactive.messaging.MediatorConfiguration

MediatorConfiguration.Consumption, MediatorConfiguration.Production

Constructor Summary

Constructors

Constructor	Description
DefaultMediatorConfiguration(Method method, javax.enterprise.inject.spi.Bean<?> bean)

Method Summary

Modifier and Type	Method	Description
void	compute(Incomings incomings, Outgoing outgoing, Blocking blocking)
void	compute(List<Incoming> incomings, Outgoing outgoing, Blocking blocking)
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()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMediatorConfiguration

public DefaultMediatorConfiguration(Method method,
                                    javax.enterprise.inject.spi.Bean<?> bean)

Method Detail

compute

public void compute(Incomings incomings,
                    Outgoing outgoing,
                    Blocking blocking)

compute

public void compute(List<Incoming> incomings,
                    Outgoing outgoing,
                    Blocking blocking)

shape

public Shape shape()

Specified by:

shape in interface MediatorConfiguration

getOutgoing

public String getOutgoing()

Specified by:

getOutgoing in interface MediatorConfiguration

getIncoming

public List<String> getIncoming()

Specified by:

getIncoming in interface MediatorConfiguration

methodAsString

public String methodAsString()

Specified by:

methodAsString in interface MediatorConfiguration

getMethod

public Method getMethod()

Specified by:

getMethod in interface MediatorConfiguration

getReturnType

public Class<?> getReturnType()

Specified by:

getReturnType in interface MediatorConfiguration

getIngestedPayloadType

public Type getIngestedPayloadType()

Specified by:

getIngestedPayloadType in interface MediatorConfiguration

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.

getParameterTypes

public Class<?>[] getParameterTypes()

Specified by:

getParameterTypes in interface MediatorConfiguration

consumption

public MediatorConfiguration.Consumption consumption()

Specified by:

consumption in interface MediatorConfiguration

production

public MediatorConfiguration.Production production()

Specified by:

production in interface MediatorConfiguration

usesBuilderTypes

public boolean usesBuilderTypes()

Specified by:

usesBuilderTypes in interface MediatorConfiguration

getAcknowledgment

public Acknowledgment.Strategy getAcknowledgment()

Specified by:

getAcknowledgment in interface MediatorConfiguration

getMerge

public Merge.Mode getMerge()

Specified by:

getMerge in interface MediatorConfiguration

getBroadcast

public boolean getBroadcast()

Specified by:

getBroadcast in interface MediatorConfiguration

getBean

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

Specified by:

getBean in interface MediatorConfiguration

getNumberOfSubscriberBeforeConnecting

public int getNumberOfSubscriberBeforeConnecting()

Specified by:

getNumberOfSubscriberBeforeConnecting in interface MediatorConfiguration

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in interface MediatorConfiguration

getWorkerPoolName

public String getWorkerPoolName()

Specified by:

getWorkerPoolName in interface MediatorConfiguration

isBlockingExecutionOrdered

public boolean isBlockingExecutionOrdered()

Specified by:

isBlockingExecutionOrdered in interface MediatorConfiguration

getInvokerClass

public Class<? extends Invoker> getInvokerClass()

Description copied from interface: MediatorConfiguration

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

Specified by:

getInvokerClass in interface MediatorConfiguration