org.springframework.integration.amqp.outbound.AsyncAmqpOutboundGateway

実装されたすべてのインターフェース:: org.reactivestreams.Subscriber<Message<?>>、Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、MessageProducer、HeaderPropagationAware、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>

public class AsyncAmqpOutboundGateway extends AbstractAmqpOutboundEndpoint

送信スレッドがすぐに解放され、応答が非同期テンプレートのリスナーコンテナースレッドで送信される送信ゲートウェイ。

導入:: 4.3
作成者:: Gary Russell, Artem Bilan

ネストされたクラスのサマリー
クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたネストクラス / インターフェース
AbstractAmqpOutboundEndpoint.CorrelationDataWrapper
クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース
AbstractReplyProducingMessageHandler.RequestHandler
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
messagingTemplate
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
コンストラクターの概要
コンストラクター
コンストラクター
説明
AsyncAmqpOutboundGateway(AsyncRabbitTemplate template)
メソッドのサマリー
修飾子と型
メソッド
説明
protected void
doStart()
protected void
doStop()
StringSE
getComponentType()
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
protected RabbitTemplate
getRabbitTemplate()
protected ObjectSE
handleRequestMessage(Message<?> requestMessage)
サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。
クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたメソッド
addDelayProperty, buildReply, buildReturnedMessage, doInit, endpointInit, generateCorrelationData, generateExchangeName, generateRoutingKey, getConfirmAckChannel, getConfirmCorrelationExpression, getConfirmNackChannel, getConfirmTimeout, getCorrelationDataGenerator, getDefaultDeliveryMode, getExchangeName, getExchangeNameExpression, getExchangeNameGenerator, getHeaderMapper, getReturnChannel, getRoutingKey, getRoutingKeyExpression, getRoutingKeyGenerator, handleConfirm, isHeadersMappedLast, isLazyConnect, isRunning, setConfirmAckChannel, setConfirmAckChannelName, setConfirmCorrelationExpression, setConfirmCorrelationExpressionString, setConfirmNackChannel, setConfirmNackChannelName, setConfirmTimeout, setConnectionFactory, setDefaultDeliveryMode, setDelay, setDelayExpression, setDelayExpressionString, setErrorMessageStrategy, setExchangeName, setExchangeNameExpression, setExchangeNameExpressionString, setHeaderMapper, setHeadersMappedLast, setLazyConnect, setReturnChannel, setRoutingKey, setRoutingKeyExpression, setRoutingKeyExpressionString, start, stop
クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたメソッド
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, setupMessageProcessor, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
handleMessage, onComplete, onError, onNext, onSubscribe, setObservationConvention
クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース reactor.core.CoreSubscriber から継承されたメソッド
currentContext
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getThisAs
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

コンストラクターの詳細
- AsyncAmqpOutboundGateway
  public AsyncAmqpOutboundGateway(AsyncRabbitTemplate template)
メソッドの詳細
- getComponentType
  public StringSE getComponentType()
  クラスからコピーされた説明: IntegrationObjectSupport
  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
  次で指定:
  インターフェース NamedComponent の getComponentType
  オーバーライド:
  クラス MessageHandlerSupport の getComponentType
- getRabbitTemplate
  protected RabbitTemplate getRabbitTemplate()
  次で指定:
  クラス AbstractAmqpOutboundEndpoint の getRabbitTemplate
- doStart
  protected void doStart()
  オーバーライド:
  クラス AbstractAmqpOutboundEndpoint の doStart
- doStop
  protected void doStop()
  オーバーライド:
  クラス AbstractAmqpOutboundEndpoint の doStop
- handleRequestMessage
  protected ObjectSE handleRequestMessage(Message<?> requestMessage)
  クラスからコピーされた説明: AbstractReplyProducingMessageHandler
  サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。戻り値は、メッセージ、MessageBuilder、任意のプレーンオブジェクトです。基本クラスは、これらの開始点のいずれかからの返信メッセージの最終的な作成を処理します。戻り値が null の場合、メッセージフローはここで終了します。
  次で指定:
  クラス AbstractReplyProducingMessageHandler の handleRequestMessage
  パラメーター:
  requestMessage - リクエストメッセージ。
  戻り値:
  メッセージを処理した結果、または null

クラス AsyncAmqpOutboundGateway

ネストされたクラスのサマリー

クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたネストクラス / インターフェース

クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

インターフェース org.springframework.core.Ordered から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.amqp.outbound.AbstractAmqpOutboundEndpoint から継承されたメソッド

クラス org.springframework.integration.handler.AbstractReplyProducingMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド

クラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース reactor.core.CoreSubscriber から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

AsyncAmqpOutboundGateway

メソッドの詳細

getComponentType

getRabbitTemplate

doStart

doStop

handleRequestMessage