Package io.smallrye.reactive.messaging

Class MediatorConfigurationSupport

java.lang.Object

io.smallrye.reactive.messaging.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
Shape	determineShape(List<?> incomingValue, Object outgoingValue)
Integer	processBroadcast(Object outgoing, Supplier<Integer> supplier)
Acknowledgment.Strategy	processDefaultAcknowledgement(Shape shape, MediatorConfiguration.Consumption consumption)
Merge.Mode	processMerge(List<?> incomings, Supplier<Merge.Mode> supplier)
Acknowledgment.Strategy	processSuppliedAcknowledgement(List<?> incomings, Supplier<Acknowledgment.Strategy> supplier)
MediatorConfigurationSupport.ValidationOutput	validate(Shape shape, 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 Detail

MediatorConfigurationSupport

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

Method Detail

determineShape

public Shape determineShape(List<?> incomingValue,
                            Object outgoingValue)

processSuppliedAcknowledgement

public Acknowledgment.Strategy processSuppliedAcknowledgement(List<?> incomings,
                                                              Supplier<Acknowledgment.Strategy> supplier)

validate

public MediatorConfigurationSupport.ValidationOutput validate(Shape shape,
                                                              Acknowledgment.Strategy acknowledgment)

processDefaultAcknowledgement

public Acknowledgment.Strategy processDefaultAcknowledgement(Shape shape,
                                                             MediatorConfiguration.Consumption consumption)

processMerge

public Merge.Mode processMerge(List<?> incomings,
                               Supplier<Merge.Mode> supplier)

processBroadcast

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

validateBlocking

public void validateBlocking(MediatorConfigurationSupport.ValidationOutput validationOutput)