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 and Description
static interface	MediatorConfigurationSupport.GenericTypeAssignable
static class	MediatorConfigurationSupport.ValidationOutput

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Shape	determineShape(List<?> incomingValue, Object outgoingValue)
Integer	processBroadcast(Object outgoing, Supplier<Integer> supplier)
Acknowledgment.Strategy	processDefaultAcknowledgement(Shape shape, MediatorConfiguration.Consumption consumption, MediatorConfiguration.Production production)
Merge.Mode	processMerge(List<?> incomings, Supplier<Merge.Mode> supplier)
Acknowledgment.Strategy	processSuppliedAcknowledgement(List<?> incomings, Supplier<Acknowledgment.Strategy> supplier)
void	strict()
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,
                                                             MediatorConfiguration.Production production)

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)

strict

public void strict()