diff --git a/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlowDefinition.java b/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlowDefinition.java index 346bc31c99..03dbd9914d 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlowDefinition.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/dsl/IntegrationFlowDefinition.java @@ -16,16 +16,38 @@ package org.springframework.integration.dsl; +import java.util.Map; +import java.util.concurrent.Executor; import java.util.function.Consumer; import java.util.function.Function; +import org.reactivestreams.Publisher; + +import org.springframework.expression.Expression; import org.springframework.integration.core.GenericSelector; +import org.springframework.integration.handler.BridgeHandler; import org.springframework.integration.handler.GenericHandler; +import org.springframework.integration.handler.LoggingHandler; +import org.springframework.integration.handler.MessageTriggerAction; import org.springframework.integration.handler.ServiceActivatingHandler; +import org.springframework.integration.router.AbstractMessageRouter; +import org.springframework.integration.router.ErrorMessageExceptionTypeRouter; +import org.springframework.integration.router.ExpressionEvaluatingRouter; import org.springframework.integration.router.MethodInvokingRouter; +import org.springframework.integration.splitter.AbstractMessageSplitter; +import org.springframework.integration.splitter.DefaultMessageSplitter; +import org.springframework.integration.splitter.ExpressionEvaluatingSplitter; import org.springframework.integration.splitter.MethodInvokingSplitter; +import org.springframework.integration.store.MessageStore; +import org.springframework.integration.support.MapBuilder; import org.springframework.integration.transformer.GenericTransformer; +import org.springframework.integration.transformer.HeaderFilter; import org.springframework.integration.transformer.MessageTransformingHandler; +import org.springframework.messaging.Message; +import org.springframework.messaging.MessageChannel; +import org.springframework.messaging.MessageHandler; + +import reactor.core.publisher.Flux; /** * The {@code BaseIntegrationFlowDefinition} extension for syntax sugar with generics for some @@ -248,4 +270,818 @@ public abstract class IntegrationFlowDefinition messageChannelSpec) { // NOSONAR - byte code backward compatibility + return super.channel(messageChannelSpec); + } + + @Override + public B channel(MessageChannel messageChannel) { // NOSONAR - byte code backward compatibility + return super.channel(messageChannel); + } + + @Override + public B channel(Function> channels) { // NOSONAR - byte code backward compatibility + return super.channel(channels); + } + + @Override + public B publishSubscribeChannel(Consumer publishSubscribeChannelConfigurer) { // NOSONAR - byte code backward compatibility + return super.publishSubscribeChannel(publishSubscribeChannelConfigurer); + } + + @Override + public B publishSubscribeChannel(Executor executor, + Consumer publishSubscribeChannelConfigurer) { // NOSONAR - byte code backward compatibility + + return super.publishSubscribeChannel(executor, publishSubscribeChannelConfigurer); + } + + @Override + public B wireTap(IntegrationFlow flow) { // NOSONAR - byte code backward compatibility + return super.wireTap(flow); + } + + @Override + public B wireTap(String wireTapChannel) { // NOSONAR - byte code backward compatibility + return super.wireTap(wireTapChannel); + } + + @Override + public B wireTap(MessageChannel wireTapChannel) { // NOSONAR - byte code backward compatibility + return super.wireTap(wireTapChannel); + } + + @Override + public B wireTap(IntegrationFlow flow, Consumer wireTapConfigurer) { // NOSONAR - byte code backward compatibility + return super.wireTap(flow, wireTapConfigurer); + } + + @Override + public B wireTap(String wireTapChannel, Consumer wireTapConfigurer) { // NOSONAR - byte code backward compatibility + return super.wireTap(wireTapChannel, wireTapConfigurer); + } + + @Override + public B wireTap(MessageChannel wireTapChannel, Consumer wireTapConfigurer) { // NOSONAR - byte code backward compatibility + return super.wireTap(wireTapChannel, wireTapConfigurer); + } + + @Override + public B wireTap(WireTapSpec wireTapSpec) { // NOSONAR - byte code backward compatibility + return super.wireTap(wireTapSpec); + } + + @Override + public B controlBus() { // NOSONAR - byte code backward compatibility + return super.controlBus(); + } + + @Override + public B controlBus(Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.controlBus(endpointConfigurer); + } + + @Override + public B transform(String expression) { // NOSONAR - byte code backward compatibility + return super.transform(expression); + } + + @Override + public B transform(String expression, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.transform(expression, endpointConfigurer); + } + + @Override + public B transform(Object service) { // NOSONAR - byte code backward compatibility + return super.transform(service); + } + + @Override + public B transform(Object service, String methodName) { // NOSONAR - byte code backward compatibility + return super.transform(service, methodName); + } + + @Override + public B transform(Object service, String methodName, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.transform(service, methodName, endpointConfigurer); + } + + @Override + public B transform(MessageProcessorSpec messageProcessorSpec) { // NOSONAR - byte code backward compatibility + return super.transform(messageProcessorSpec); + } + + @Override + public B transform(MessageProcessorSpec messageProcessorSpec, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.transform(messageProcessorSpec, endpointConfigurer); + } + + @Override + public

B convert(Class

payloadType) { // NOSONAR - byte code backward compatibility + return super.convert(payloadType); + } + + @Override + public B transform(Class

payloadType, GenericTransformer genericTransformer) { // NOSONAR - byte code backward compatibility + return super.transform(payloadType, genericTransformer); + } + + @Override + public

B convert(Class

payloadType, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.convert(payloadType, endpointConfigurer); + } + + @Override + public B transform(Class

payloadType, GenericTransformer genericTransformer, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.transform(payloadType, genericTransformer, endpointConfigurer); + } + + @Override + public B filter(String expression) { // NOSONAR - byte code backward compatibility + return super.filter(expression); + } + + @Override + public B filter(String expression, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.filter(expression, endpointConfigurer); + } + + @Override + public B filter(Object service) { // NOSONAR - byte code backward compatibility + return super.filter(service); + } + + @Override + public B filter(Object service, String methodName) { // NOSONAR - byte code backward compatibility + return super.filter(service, methodName); + } + + @Override + public B filter(Object service, String methodName, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.filter(service, methodName, endpointConfigurer); + } + + @Override + public B filter(MessageProcessorSpec messageProcessorSpec) { // NOSONAR - byte code backward compatibility + return super.filter(messageProcessorSpec); + } + + @Override + public B filter(MessageProcessorSpec messageProcessorSpec, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.filter(messageProcessorSpec, endpointConfigurer); + } + + @Override + public

B filter(Class

payloadType, GenericSelector

genericSelector) { // NOSONAR - byte code backward compatibility + return super.filter(payloadType, genericSelector); + } + + @Override + public

B filter(Class

payloadType, GenericSelector

genericSelector, + Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.filter(payloadType, genericSelector, endpointConfigurer); + } + + @Override + public B handle(MessageHandlerSpec messageHandlerSpec) { // NOSONAR - byte code backward compatibility + return super.handle(messageHandlerSpec); + } + + @Override + public B handle(MessageHandler messageHandler) { // NOSONAR - byte code backward compatibility + return super.handle(messageHandler); + } + + @Override + public B handle(String beanName, String methodName) { // NOSONAR - byte code backward compatibility + return super.handle(beanName, methodName); + } + + @Override + public B handle(String beanName, String methodName, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.handle(beanName, methodName, endpointConfigurer); + } + + @Override + public B handle(Object service) { // NOSONAR - byte code backward compatibility + return super.handle(service); + } + + @Override + public B handle(Object service, String methodName) { // NOSONAR - byte code backward compatibility + return super.handle(service, methodName); + } + + @Override + public B handle(Object service, String methodName, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.handle(service, methodName, endpointConfigurer); + } + + @Override + public

B handle(Class

payloadType, GenericHandler

handler) { // NOSONAR - byte code backward compatibility + return super.handle(payloadType, handler); + } + + @Override + public

B handle(Class

payloadType, GenericHandler

handler, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.handle(payloadType, handler, endpointConfigurer); + } + + @Override + public B handle(MessageProcessorSpec messageProcessorSpec) { // NOSONAR - byte code backward compatibility + return super.handle(messageProcessorSpec); + } + + @Override + public B handle(MessageProcessorSpec messageProcessorSpec, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.handle(messageProcessorSpec, endpointConfigurer); + } + + @Override + public B handle(MessageHandlerSpec messageHandlerSpec, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.handle(messageHandlerSpec, endpointConfigurer); + } + + @Override + public B handle(H messageHandler, Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.handle(messageHandler, endpointConfigurer); + } + + @Override + public B bridge() { // NOSONAR - byte code backward compatibility + return super.bridge(); + } + + @Override + public B bridge(Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.bridge(endpointConfigurer); + } + + @Override + public B delay(String groupId) { // NOSONAR - byte code backward compatibility + return super.delay(groupId); + } + + @Override + public B delay(String groupId, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.delay(groupId, endpointConfigurer); + } + + @Override + public B enrich(Consumer enricherConfigurer) { // NOSONAR - byte code backward compatibility + return super.enrich(enricherConfigurer); + } + + @Override + public B enrichHeaders(MapBuilder headers) { // NOSONAR - byte code backward compatibility + return super.enrichHeaders(headers); + } + + @Override + public B enrichHeaders(MapBuilder headers, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.enrichHeaders(headers, endpointConfigurer); + } + + @Override + public B enrichHeaders(Map headers, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.enrichHeaders(headers, endpointConfigurer); + } + + @Override + public B enrichHeaders(Consumer headerEnricherConfigurer) { // NOSONAR - byte code backward compatibility + return super.enrichHeaders(headerEnricherConfigurer); + } + + @Override + public B split() { // NOSONAR - byte code backward compatibility + return super.split(); + } + + @Override + public B split(Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.split(endpointConfigurer); + } + + @Override + public B split(String expression) { // NOSONAR - byte code backward compatibility + return super.split(expression); + } + + @Override + public B split(String expression, Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.split(expression, endpointConfigurer); + } + + @Override + public B split(Object service) { // NOSONAR - byte code backward compatibility + return super.split(service); + } + + @Override + public B split(Object service, String methodName) { // NOSONAR - byte code backward compatibility + return super.split(service, methodName); + } + + @Override + public B split(Object service, String methodName, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.split(service, methodName, endpointConfigurer); + } + + @Override + public B split(String beanName, String methodName) { // NOSONAR - byte code backward compatibility + return super.split(beanName, methodName); + } + + @Override + public B split(String beanName, String methodName, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.split(beanName, methodName, endpointConfigurer); + } + + @Override + public B split(MessageProcessorSpec messageProcessorSpec) { // NOSONAR - byte code backward compatibility + return super.split(messageProcessorSpec); + } + + @Override + public B split(MessageProcessorSpec messageProcessorSpec, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.split(messageProcessorSpec, endpointConfigurer); + } + + @Override + public

B split(Class

payloadType, Function splitter) { // NOSONAR - byte code backward compatibility + return super.split(payloadType, splitter); + } + + @Override + public

B split(Class

payloadType, Function splitter, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.split(payloadType, splitter, endpointConfigurer); + } + + @Override + public B split(MessageHandlerSpec splitterMessageHandlerSpec) { // NOSONAR - byte code backward compatibility + return super.split(splitterMessageHandlerSpec); + } + + @Override + public B split(MessageHandlerSpec splitterMessageHandlerSpec, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.split(splitterMessageHandlerSpec, endpointConfigurer); + } + + @Override + public B split(AbstractMessageSplitter splitter) { // NOSONAR - byte code backward compatibility + return super.split(splitter); + } + + @Override + public B split(S splitter, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.split(splitter, endpointConfigurer); + } + + @Override + public B headerFilter(String... headersToRemove) { // NOSONAR - byte code backward compatibility + return super.headerFilter(headersToRemove); + } + + @Override + public B headerFilter(String headersToRemove, boolean patternMatch) { // NOSONAR - byte code backward compatibility + return super.headerFilter(headersToRemove, patternMatch); + } + + @Override + public B headerFilter(HeaderFilter headerFilter, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.headerFilter(headerFilter, endpointConfigurer); + } + + @Override + public B claimCheckIn(MessageStore messageStore) { // NOSONAR - byte code backward compatibility + return super.claimCheckIn(messageStore); + } + + @Override + public B claimCheckIn(MessageStore messageStore, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.claimCheckIn(messageStore, endpointConfigurer); + } + + @Override + public B claimCheckOut(MessageStore messageStore) { // NOSONAR - byte code backward compatibility + return super.claimCheckOut(messageStore); + } + + @Override + public B claimCheckOut(MessageStore messageStore, boolean removeMessage) { // NOSONAR - byte code backward compatibility + return super.claimCheckOut(messageStore, removeMessage); + } + + @Override + public B claimCheckOut(MessageStore messageStore, boolean removeMessage, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.claimCheckOut(messageStore, removeMessage, endpointConfigurer); + } + + @Override + public B resequence() { // NOSONAR - byte code backward compatibility + return super.resequence(); + } + + @Override + public B resequence(Consumer resequencer) { // NOSONAR - byte code backward compatibility + return super.resequence(resequencer); + } + + @Override + public B aggregate() { // NOSONAR - byte code backward compatibility + return super.aggregate(); + } + + @Override + public B aggregate(Consumer aggregator) { // NOSONAR - byte code backward compatibility + return super.aggregate(aggregator); + } + + @Override + public B route(String beanName, String method) { // NOSONAR - byte code backward compatibility + return super.route(beanName, method); + } + + @Override + public B route(String beanName, String method, + Consumer> routerConfigurer) { // NOSONAR - byte code backward compatibility + + return super.route(beanName, method, routerConfigurer); + } + + @Override + public B route(Object service) { // NOSONAR - byte code backward compatibility + return super.route(service); + } + + @Override + public B route(Object service, String methodName) { // NOSONAR - byte code backward compatibility + return super.route(service, methodName); + } + + @Override + public B route(Object service, String methodName, + Consumer> routerConfigurer) { // NOSONAR - byte code backward compatibility + + return super.route(service, methodName, routerConfigurer); + } + + @Override + public B route(String expression) { // NOSONAR - byte code backward compatibility + return super.route(expression); + } + + @Override + public B route(String expression, Consumer> routerConfigurer) { // NOSONAR - byte code backward compatibility + return super.route(expression, routerConfigurer); + } + + @Override + public B route(Class payloadType, Function router) { // NOSONAR - byte code backward compatibility + return super.route(payloadType, router); + } + + @Override + public B route(Class

payloadType, Function router, + Consumer> routerConfigurer) { // NOSONAR - byte code backward compatibility + return super.route(payloadType, router, routerConfigurer); + } + + @Override + public B route(MessageProcessorSpec messageProcessorSpec) { // NOSONAR - byte code backward compatibility + return super.route(messageProcessorSpec); + } + + @Override + public B route(MessageProcessorSpec messageProcessorSpec, + Consumer> routerConfigurer) { // NOSONAR - byte code backward compatibility + + return super.route(messageProcessorSpec, routerConfigurer); + } + + @Override + public B routeToRecipients(Consumer routerConfigurer) { // NOSONAR - byte code backward compatibility + return super.routeToRecipients(routerConfigurer); + } + + @Override + public B routeByException(Consumer, // NOSONAR - byte code backward compatibility + ErrorMessageExceptionTypeRouter>> routerConfigurer) { + + return super.routeByException(routerConfigurer); + } + + @Override + public B route(AbstractMessageRouter router) { // NOSONAR - byte code backward compatibility + return super.route(router); + } + + @Override + public B route(R router, Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.route(router, endpointConfigurer); + } + + @Override + public B gateway(String requestChannel) { // NOSONAR - byte code backward compatibility + return super.gateway(requestChannel); + } + + @Override + public B gateway(String requestChannel, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.gateway(requestChannel, endpointConfigurer); + } + + @Override + public B gateway(MessageChannel requestChannel) { // NOSONAR - byte code backward compatibility + return super.gateway(requestChannel); + } + + @Override + public B gateway(MessageChannel requestChannel, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.gateway(requestChannel, endpointConfigurer); + } + + @Override + public B gateway(IntegrationFlow flow) { // NOSONAR - byte code backward compatibility + return super.gateway(flow); + } + + @Override + public B gateway(IntegrationFlow flow, Consumer endpointConfigurer) { // NOSONAR - byte code backward compatibility + return super.gateway(flow, endpointConfigurer); + } + + @Override + public B log() { // NOSONAR - byte code backward compatibility + return super.log(); + } + + @Override + public B log(LoggingHandler.Level level) { // NOSONAR - byte code backward compatibility + return super.log(level); + } + + @Override + public B log(String category) { // NOSONAR - byte code backward compatibility + return super.log(category); + } + + @Override + public B log(LoggingHandler.Level level, String category) { // NOSONAR - byte code backward compatibility + return super.log(level, category); + } + + @Override + public B log(LoggingHandler.Level level, String category, String logExpression) { // NOSONAR - byte code backward compatibility + return super.log(level, category, logExpression); + } + + @Override + public

B log(Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.log(function); + } + + @Override + public B log(Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.log(logExpression); + } + + @Override + public B log(LoggingHandler.Level level, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.log(level, logExpression); + } + + @Override + public B log(String category, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.log(category, logExpression); + } + + @Override + public

B log(LoggingHandler.Level level, Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.log(level, function); + } + + @Override + public

B log(String category, Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.log(category, function); + } + + @Override + public

B log(LoggingHandler.Level level, String category, Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.log(level, category, function); + } + + @Override + public B log(LoggingHandler.Level level, String category, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.log(level, category, logExpression); + } + + @Override + public IntegrationFlow logAndReply() { // NOSONAR - byte code backward compatibility + return super.logAndReply(); + } + + @Override + public IntegrationFlow logAndReply(LoggingHandler.Level level) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level); + } + + @Override + public IntegrationFlow logAndReply(String category) { // NOSONAR - byte code backward compatibility + return super.logAndReply(category); + } + + @Override + public IntegrationFlow logAndReply(LoggingHandler.Level level, String category) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level, category); + } + + @Override + public IntegrationFlow logAndReply(LoggingHandler.Level level, String category, String logExpression) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level, category, logExpression); + } + + @Override + public

IntegrationFlow logAndReply(Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.logAndReply(function); + } + + @Override + public IntegrationFlow logAndReply(Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.logAndReply(logExpression); + } + + @Override + public IntegrationFlow logAndReply(LoggingHandler.Level level, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level, logExpression); + } + + @Override + public IntegrationFlow logAndReply(String category, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.logAndReply(category, logExpression); + } + + @Override + public

IntegrationFlow logAndReply(LoggingHandler.Level level, Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level, function); + } + + @Override + public

IntegrationFlow logAndReply(String category, Function, Object> function) { // NOSONAR - byte code backward compatibility + return super.logAndReply(category, function); + } + + @Override + public

IntegrationFlow logAndReply(LoggingHandler.Level level, String category, + Function, Object> function) { // NOSONAR - byte code backward compatibility + + return super.logAndReply(level, category, function); + } + + @Override + public IntegrationFlow logAndReply(LoggingHandler.Level level, String category, Expression logExpression) { // NOSONAR - byte code backward compatibility + return super.logAndReply(level, category, logExpression); + } + + @Override + public B scatterGather(MessageChannel scatterChannel) { // NOSONAR - byte code backward compatibility + return super.scatterGather(scatterChannel); + } + + @Override + public B scatterGather(MessageChannel scatterChannel, Consumer gatherer) { // NOSONAR - byte code backward compatibility + return super.scatterGather(scatterChannel, gatherer); + } + + @Override + public B scatterGather(MessageChannel scatterChannel, Consumer gatherer, + Consumer scatterGather) { // NOSONAR - byte code backward compatibility + + return super.scatterGather(scatterChannel, gatherer, scatterGather); + } + + @Override + public B scatterGather(Consumer scatterer) { // NOSONAR - byte code backward compatibility + return super.scatterGather(scatterer); + } + + @Override + public B scatterGather(Consumer scatterer, Consumer gatherer) { // NOSONAR - byte code backward compatibility + return super.scatterGather(scatterer, gatherer); + } + + @Override + public B scatterGather(Consumer scatterer, Consumer gatherer, + Consumer scatterGather) { // NOSONAR - byte code backward compatibility + + return super.scatterGather(scatterer, gatherer, scatterGather); + } + + @Override + public B barrier(long timeout) { // NOSONAR - byte code backward compatibility + return super.barrier(timeout); + } + + @Override + public B barrier(long timeout, Consumer barrierConfigurer) { // NOSONAR - byte code backward compatibility + return super.barrier(timeout, barrierConfigurer); + } + + @Override + public B trigger(String triggerActionId) { // NOSONAR - byte code backward compatibility + return super.trigger(triggerActionId); + } + + @Override + public B trigger(String triggerActionId, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.trigger(triggerActionId, endpointConfigurer); + } + + @Override + public B trigger(MessageTriggerAction triggerAction) { // NOSONAR - byte code backward compatibility + return super.trigger(triggerAction); + } + + @Override + public B trigger(MessageTriggerAction triggerAction, + Consumer> endpointConfigurer) { // NOSONAR - byte code backward compatibility + + return super.trigger(triggerAction, endpointConfigurer); + } + + @Override + public B fluxTransform(Function>, ? extends Publisher> fluxFunction) { // NOSONAR - byte code backward compatibility + return super.fluxTransform(fluxFunction); + } + + @Override + public IntegrationFlow nullChannel() { // NOSONAR - byte code backward compatibility + return super.nullChannel(); + } + + @Override + public B enrichHeaders(Map headers) { // NOSONAR - byte code backward compatibility + return super.enrichHeaders(headers); + } + }