Package io.smallrye.reactive.messaging.providers

Class MediatorConfigurationSupport

java.lang.Object

io.smallrye.reactive.messaging.providers.MediatorConfigurationSupport

public class MediatorConfigurationSupport
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MediatorConfigurationSupport.GenericTypeAssignable
static class	MediatorConfigurationSupport.ValidationOutput

Constructor Summary

Constructors

Constructor	Description
MediatorConfigurationSupport(String methodAsString, Class<?> returnType, Class<?>[] parameterTypes, MediatorConfigurationSupport.GenericTypeAssignable returnTypeAssignable, MediatorConfigurationSupport.GenericTypeAssignable firstMethodParamTypeAssignable)

Method Summary

Modifier and Type	Method	Description
io.smallrye.reactive.messaging.Shape	determineShape(List<?> incomingValue, List<?> outgoingValue)
Integer	processBroadcast(Object outgoing, Supplier<Integer> supplier)
org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy	processDefaultAcknowledgement(io.smallrye.reactive.messaging.Shape shape, io.smallrye.reactive.messaging.MediatorConfiguration.Consumption consumption, io.smallrye.reactive.messaging.MediatorConfiguration.Production production)
io.smallrye.reactive.messaging.annotations.Merge.Mode	processMerge(List<?> incomings, Supplier<io.smallrye.reactive.messaging.annotations.Merge.Mode> supplier)
org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy	processSuppliedAcknowledgement(List<?> incomings, Supplier<org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy> supplier)
boolean	processTargetedOutput()
void	strict()
MediatorConfigurationSupport.ValidationOutput	validate(io.smallrye.reactive.messaging.Shape shape, org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy acknowledgment)
void	validateBlocking(MediatorConfigurationSupport.ValidationOutput validationOutput)

Methods inherited from class java.lang.Object

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

Constructor Details

MediatorConfigurationSupport

public MediatorConfigurationSupport(String methodAsString,
 Class<?> returnType,
 Class<?>[] parameterTypes,
 MediatorConfigurationSupport.GenericTypeAssignable returnTypeAssignable,
 MediatorConfigurationSupport.GenericTypeAssignable firstMethodParamTypeAssignable)

Method Details

determineShape

public io.smallrye.reactive.messaging.Shape determineShape(List<?> incomingValue,
 List<?> outgoingValue)

processSuppliedAcknowledgement

public org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy processSuppliedAcknowledgement(List<?> incomings,
 Supplier<org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy> supplier)

validate

public MediatorConfigurationSupport.ValidationOutput validate(io.smallrye.reactive.messaging.Shape shape,
 org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy acknowledgment)

processDefaultAcknowledgement

public org.eclipse.microprofile.reactive.messaging.Acknowledgment.Strategy processDefaultAcknowledgement(io.smallrye.reactive.messaging.Shape shape,
 io.smallrye.reactive.messaging.MediatorConfiguration.Consumption consumption,
 io.smallrye.reactive.messaging.MediatorConfiguration.Production production)

processMerge

public io.smallrye.reactive.messaging.annotations.Merge.Mode processMerge(List<?> incomings,
 Supplier<io.smallrye.reactive.messaging.annotations.Merge.Mode> supplier)

processBroadcast

public Integer processBroadcast(Object outgoing,
 Supplier<Integer> supplier)

processTargetedOutput

public boolean processTargetedOutput()

validateBlocking

public void validateBlocking(MediatorConfigurationSupport.ValidationOutput validationOutput)

strict

public void strict()