Package io.smallrye.reactive.messaging.providers

Class DefaultMediatorConfiguration

java.lang.Object

io.smallrye.reactive.messaging.providers.DefaultMediatorConfiguration

All Implemented Interfaces:

io.smallrye.reactive.messaging.MediatorConfiguration

public class DefaultMediatorConfiguration
extends Object
implements io.smallrye.reactive.messaging.MediatorConfiguration

Nested Class Summary

Nested Classes

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

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

io.smallrye.reactive.messaging.MediatorConfiguration.Consumption, io.smallrye.reactive.messaging.MediatorConfiguration.Production

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	compute(io.smallrye.reactive.messaging.annotations.Incomings incomings, io.smallrye.reactive.messaging.annotations.Outgoings outgoings, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(io.smallrye.reactive.messaging.annotations.Incomings incomings, List<org.eclipse.microprofile.reactive.messaging.Outgoing> outgoings, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(io.smallrye.reactive.messaging.annotations.Incomings incomings, org.eclipse.microprofile.reactive.messaging.Outgoing outgoing, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings, io.smallrye.reactive.messaging.annotations.Outgoings outgoings, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings, List<org.eclipse.microprofile.reactive.messaging.Outgoing> outgoings, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings, org.eclipse.microprofile.reactive.messaging.Outgoing outgoing, io.smallrye.reactive.messaging.annotations.Blocking blocking)
void	compute(org.eclipse.microprofile.reactive.messaging.Incoming incoming, io.smallrye.reactive.messaging.annotations.Outgoings outgoings, io.smallrye.reactive.messaging.annotations.Blocking blocking)
io.smallrye.reactive.messaging.MediatorConfiguration.Consumption	consumption()
org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy	getAcknowledgment()
jakarta.enterprise.inject.spi.Bean<?>	getBean()
boolean	getBroadcast()
List<String>	getIncoming()
Type	getIngestedPayloadType()
Class<? extends io.smallrye.reactive.messaging.Invoker>	getInvokerClass()
Class<? extends io.smallrye.reactive.messaging.keyed.KeyValueExtractor>	getKeyed()
Type	getKeyType()
io.smallrye.reactive.messaging.annotations.Merge.Mode	getMerge()
Method	getMethod()
int	getNumberOfSubscriberBeforeConnecting()
String	getOutgoing()
List<String>	getOutgoings()
io.smallrye.reactive.messaging.MethodParameterDescriptor	getParameterDescriptor()
Class<?>	getReturnType()
Type	getValueType()
String	getWorkerPoolName()
boolean	hasTargetedOutput()
boolean	isBlocking()
boolean	isBlockingExecutionOrdered()
String	methodAsString()
io.smallrye.reactive.messaging.MediatorConfiguration.Production	production()
io.smallrye.reactive.messaging.Shape	shape()
void	strict()
boolean	usesBuilderTypes()
boolean	usesReactiveStreams()

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultMediatorConfiguration

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

Method Details

compute

public void compute(io.smallrye.reactive.messaging.annotations.Incomings incomings,
 org.eclipse.microprofile.reactive.messaging.Outgoing outgoing,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(io.smallrye.reactive.messaging.annotations.Incomings incomings,
 io.smallrye.reactive.messaging.annotations.Outgoings outgoings,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(io.smallrye.reactive.messaging.annotations.Incomings incomings,
 List<org.eclipse.microprofile.reactive.messaging.Outgoing> outgoings,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(org.eclipse.microprofile.reactive.messaging.Incoming incoming,
 io.smallrye.reactive.messaging.annotations.Outgoings outgoings,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings,
 org.eclipse.microprofile.reactive.messaging.Outgoing outgoing,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings,
 io.smallrye.reactive.messaging.annotations.Outgoings outgoings,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

compute

public void compute(List<org.eclipse.microprofile.reactive.messaging.Incoming> incomings,
 List<org.eclipse.microprofile.reactive.messaging.Outgoing> outgoings,
 io.smallrye.reactive.messaging.annotations.Blocking blocking)

shape

public io.smallrye.reactive.messaging.Shape shape()

Specified by:

shape in interface io.smallrye.reactive.messaging.MediatorConfiguration

getOutgoing

public String getOutgoing()

Specified by:

getOutgoing in interface io.smallrye.reactive.messaging.MediatorConfiguration

getOutgoings

public List<String> getOutgoings()

Specified by:

getOutgoings in interface io.smallrye.reactive.messaging.MediatorConfiguration

getIncoming

public List<String> getIncoming()

Specified by:

getIncoming in interface io.smallrye.reactive.messaging.MediatorConfiguration

methodAsString

public String methodAsString()

Specified by:

methodAsString in interface io.smallrye.reactive.messaging.MediatorConfiguration

getMethod

public Method getMethod()

Specified by:

getMethod in interface io.smallrye.reactive.messaging.MediatorConfiguration

getReturnType

public Class<?> getReturnType()

Specified by:

getReturnType in interface io.smallrye.reactive.messaging.MediatorConfiguration

getIngestedPayloadType

public Type getIngestedPayloadType()

Specified by:

getIngestedPayloadType in interface io.smallrye.reactive.messaging.MediatorConfiguration

getParameterDescriptor

public io.smallrye.reactive.messaging.MethodParameterDescriptor getParameterDescriptor()

Specified by:

getParameterDescriptor in interface io.smallrye.reactive.messaging.MediatorConfiguration

hasTargetedOutput

public boolean hasTargetedOutput()

Specified by:

hasTargetedOutput in interface io.smallrye.reactive.messaging.MediatorConfiguration

consumption

public io.smallrye.reactive.messaging.MediatorConfiguration.Consumption consumption()

Specified by:

consumption in interface io.smallrye.reactive.messaging.MediatorConfiguration

production

public io.smallrye.reactive.messaging.MediatorConfiguration.Production production()

Specified by:

production in interface io.smallrye.reactive.messaging.MediatorConfiguration

usesBuilderTypes

public boolean usesBuilderTypes()

Specified by:

usesBuilderTypes in interface io.smallrye.reactive.messaging.MediatorConfiguration

usesReactiveStreams

public boolean usesReactiveStreams()

Specified by:

usesReactiveStreams in interface io.smallrye.reactive.messaging.MediatorConfiguration

getAcknowledgment

public org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy getAcknowledgment()

Specified by:

getAcknowledgment in interface io.smallrye.reactive.messaging.MediatorConfiguration

getMerge

public io.smallrye.reactive.messaging.annotations.Merge.Mode getMerge()

Specified by:

getMerge in interface io.smallrye.reactive.messaging.MediatorConfiguration

getBroadcast

public boolean getBroadcast()

Specified by:

getBroadcast in interface io.smallrye.reactive.messaging.MediatorConfiguration

getBean

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

Specified by:

getBean in interface io.smallrye.reactive.messaging.MediatorConfiguration

getNumberOfSubscriberBeforeConnecting

public int getNumberOfSubscriberBeforeConnecting()

Specified by:

getNumberOfSubscriberBeforeConnecting in interface io.smallrye.reactive.messaging.MediatorConfiguration

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in interface io.smallrye.reactive.messaging.MediatorConfiguration

getWorkerPoolName

public String getWorkerPoolName()

Specified by:

getWorkerPoolName in interface io.smallrye.reactive.messaging.MediatorConfiguration

isBlockingExecutionOrdered

public boolean isBlockingExecutionOrdered()

Specified by:

isBlockingExecutionOrdered in interface io.smallrye.reactive.messaging.MediatorConfiguration

getInvokerClass

public Class<? extends io.smallrye.reactive.messaging.Invoker> getInvokerClass()

Specified by:

getInvokerClass in interface io.smallrye.reactive.messaging.MediatorConfiguration

strict

public void strict()

getKeyType

public Type getKeyType()

Specified by:

getKeyType in interface io.smallrye.reactive.messaging.MediatorConfiguration

getValueType

public Type getValueType()

Specified by:

getValueType in interface io.smallrye.reactive.messaging.MediatorConfiguration

getKeyed

public Class<? extends io.smallrye.reactive.messaging.keyed.KeyValueExtractor> getKeyed()

Specified by:

getKeyed in interface io.smallrye.reactive.messaging.MediatorConfiguration