Class WebFluxInboundEndpoint

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.gateway.MessagingGatewaySupport
org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.context.OrderlyShutdownCapable, org.springframework.integration.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.IntegrationInboundManagement, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.ManageableLifecycle, org.springframework.integration.support.management.ManageableSmartLifecycle, org.springframework.integration.support.management.TrackableComponent, org.springframework.web.server.WebHandler

public class WebFluxInboundEndpoint
extends org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
implements org.springframework.web.server.WebHandler
A MessagingGatewaySupport implementation for Spring WebFlux HTTP requests execution.
Since:
5.0
See Also:
HandlerResultHandlerSupport, EnableWebFlux
  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

    org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides
  • Field Summary

    Fields inherited from class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

    activeCount, JAXB_PRESENT, NON_READABLE_BODY_HTTP_METHODS, ROME_TOOLS_PRESENT

    Fields inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

    messagingTemplate

    Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    lifecycleCondition, lifecycleLock

    Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

    EXPRESSION_PARSER, logger

    Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

    METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

    Fields inherited from interface org.springframework.context.SmartLifecycle

    DEFAULT_PHASE
  • Constructor Summary

    Constructors 
    Constructor Description
    WebFluxInboundEndpoint()  
    WebFluxInboundEndpoint​(boolean expectReply)  
  • Method Summary

    Modifier and Type Method Description
    java.lang.String getComponentType()  
    reactor.core.publisher.Mono<java.lang.Void> handle​(org.springframework.web.server.ServerWebExchange exchange)  
    void setCodecConfigurer​(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer)
    A ServerCodecConfigurer for the request readers and response writers.
    void setReactiveAdapterRegistry​(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)
    A registry of adapters to adapt a Reactive Streams Publisher to/from.
    void setRequestedContentTypeResolver​(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver)
    A strategy to resolve the requested media types for a ServerWebExchange.

    Methods inherited from class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint

    afterShutdown, beforeShutdown, createEvaluationContext, evaluateHttpStatus, getCrossOrigin, getExtractReplyPayload, getHeaderExpressions, getHeaderMapper, getIntegrationPatternType, getPayloadExpression, getRequestMapping, getRequestPayloadType, getStatusCodeExpression, getValidator, isExpectReply, isReadable, onInit, resolveHttpStatusFromHeaders, setCrossOrigin, setExtractReplyPayload, setHeaderExpressions, setHeaderMapper, setPayloadExpression, setRequestMapping, setRequestPayloadType, setRequestPayloadTypeClass, setStatusCodeExpression, setStatusCodeExpressionString, setValidator, validate

    Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

    buildErrorMessage, buildSendTimer, destroy, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerMetricsCaptor, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setErrorOnTimeout, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannel, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack

    Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

    doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

    Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

    afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

    getThisAs

    Methods inherited from interface org.springframework.integration.support.context.NamedComponent

    getBeanName, getComponentName
  • Constructor Details

  • Method Details

    • setCodecConfigurer

      public void setCodecConfigurer​(org.springframework.http.codec.ServerCodecConfigurer codecConfigurer)
      A ServerCodecConfigurer for the request readers and response writers. By default the ServerCodecConfigurer.create() factory is used.
      Parameters:
      codecConfigurer - the ServerCodecConfigurer to use.
    • setRequestedContentTypeResolver

      public void setRequestedContentTypeResolver​(org.springframework.web.reactive.accept.RequestedContentTypeResolver requestedContentTypeResolver)
      A strategy to resolve the requested media types for a ServerWebExchange. A HeaderContentTypeResolver is used by default.
      Parameters:
      requestedContentTypeResolver - the RequestedContentTypeResolver to use.
    • setReactiveAdapterRegistry

      public void setReactiveAdapterRegistry​(org.springframework.core.ReactiveAdapterRegistry adapterRegistry)
      A registry of adapters to adapt a Reactive Streams Publisher to/from.
      Parameters:
      adapterRegistry - the ReactiveAdapterRegistry to use.
    • getComponentType

      public java.lang.String getComponentType()
      Specified by:
      getComponentType in interface org.springframework.integration.support.context.NamedComponent
      Overrides:
      getComponentType in class org.springframework.integration.http.inbound.BaseHttpInboundEndpoint
    • handle

      public reactor.core.publisher.Mono<java.lang.Void> handle​(org.springframework.web.server.ServerWebExchange exchange)
      Specified by:
      handle in interface org.springframework.web.server.WebHandler