Package org.springframework.cloud.function.integration.dsl

Class FunctionFlowDefinition

java.lang.Object
org.springframework.integration.dsl.BaseIntegrationFlowDefinition<B>
org.springframework.integration.dsl.IntegrationFlowDefinition<B>
org.springframework.integration.dsl.IntegrationFlowExtension<FunctionFlowDefinition>
org.springframework.cloud.function.integration.dsl.FunctionFlowDefinition
public final class FunctionFlowDefinition extends org.springframework.integration.dsl.IntegrationFlowExtension<FunctionFlowDefinition>
The IntegrationFlowExtension implementation for Spring Cloud Function domain. Adds operators for functions and consumers and overloaded versions based on their names or definitions resolved from the provided FunctionCatalog.
Since:
4.0.3
Author:
Artem Bilan

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

    org.springframework.integration.dsl.BaseIntegrationFlowDefinition.ReplyProducerCleaner

  • Field Summary

    Fields inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

    integrationComponents, PARSER

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.integration.dsl.IntegrationFlow
    accept(String consumerDefinition)
    Configure a SimpleFunctionRegistry.FunctionInvocationWrapper as a one-way handler in the final endpoint by its definition from the FunctionCatalog.
    org.springframework.integration.dsl.IntegrationFlow
    accept(Consumer<org.springframework.messaging.Message<?>> consumer)
    Configure a Consumer as a one-way handler in the final endpoint.
    FunctionFlowDefinition
    apply(String functionDefinition)
    Configure a SimpleFunctionRegistry.FunctionInvocationWrapper as a handler in the endpoint by its definition from the FunctionCatalog.
    FunctionFlowDefinition
    apply(Function<org.springframework.messaging.Message<?>,?> function)
    Configure a Function as a handler in the endpoint.

    Methods inherited from class org.springframework.integration.dsl.IntegrationFlowExtension

    get

    Methods inherited from class org.springframework.integration.dsl.IntegrationFlowDefinition

    filter, filter, handle, handle, route, route, transform

    Methods inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

    _this, addComponent, addComponent, addComponents, aggregate, aggregate, aggregate, barrier, barrier, bridge, bridge, channel, channel, channel, channel, checkReuse, claimCheckIn, claimCheckIn, claimCheckOut, claimCheckOut, claimCheckOut, controlBus, controlBus, controlBusOnRegistry, controlBusOnRegistry, convert, convert, currentComponent, currentInterceptableChannel, currentMessageChannel, delay, delay, enrich, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, extractProxyTarget, filter, filter, filter, filter, filter, filter, filter, filter, filter, fixedSubscriberChannel, fixedSubscriberChannel, fluxTransform, gateway, gateway, gateway, gateway, gateway, gateway, getCurrentComponent, getCurrentMessageChannel, getIntegrationComponents, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handleReactive, handleReactive, handleReactive, handleReactive, headerFilter, headerFilter, headerFilter, intercept, isImplicitChannel, isOutputChannelRequired, log, log, log, log, log, log, log, log, log, log, log, log, log, nullChannel, obtainInputChannelFromFlow, publishSubscribeChannel, publishSubscribeChannel, publishSubscribeChannel, register, registerOutputChannelIfCan, resequence, resequence, route, route, route, route, route, route, route, route, route, route, route, route, route, route, routeByException, routeToRecipients, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, setImplicitChannel, split, split, split, split, split, split, split, split, split, splitWith, to, toReactivePublisher, toReactivePublisher, transform, transform, transform, transform, transform, transform, transformWith, trigger, trigger, trigger, trigger, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap

    Methods inherited from class java.lang.Object

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

  • Method Details

    • apply

      public FunctionFlowDefinition apply(String functionDefinition)
      Configure a SimpleFunctionRegistry.FunctionInvocationWrapper as a handler in the endpoint by its definition from the FunctionCatalog.
      Parameters:
      functionDefinition - the function definition in the function catalog.
      Returns:
      the current flow builder.

    • apply

      public FunctionFlowDefinition apply(Function<org.springframework.messaging.Message<?>,?> function)
      Configure a Function as a handler in the endpoint.
      Parameters:
      function - the Function to use.
      Returns:
      the current flow builder.

    • accept

      public org.springframework.integration.dsl.IntegrationFlow accept(String consumerDefinition)
      Configure a SimpleFunctionRegistry.FunctionInvocationWrapper as a one-way handler in the final endpoint by its definition from the FunctionCatalog.
      Parameters:
      consumerDefinition - the consumer definition in the function catalog.
      Returns:
      the current flow builder.

    • accept

      public org.springframework.integration.dsl.IntegrationFlow accept(Consumer<org.springframework.messaging.Message<?>> consumer)
      Configure a Consumer as a one-way handler in the final endpoint.
      Parameters:
      consumer - the Consumer to use.
      Returns:
      the current flow builder.