AbstractReactorMessageHandler (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.handler.AbstractMessageHandler
  - - org.springframework.integration.handler.AbstractMessageProducingHandler
    - - org.springframework.xd.reactor.AbstractReactorMessageHandler

実装済みのインターフェース一覧:
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.core.Ordered, org.springframework.integration.context.Orderable, org.springframework.integration.core.MessageProducer, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageHandlerMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageHandlerMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler
既知の直属サブクラス
BroadcasterMessageHandler, MultipleBroadcasterMessageHandler
```
public abstract class AbstractReactorMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
implements org.springframework.beans.factory.DisposableBean
```
Reactor ベースの MessageHandlers の抽象基本クラス。
作成者:
Mark Pollack

ネストされたクラスの概要
ネストされたクラス
修飾子と型クラスと説明
protected class AbstractReactorMessageHandler.ChannelForwardingSubscriber

ネストされたクラス
修飾子と型	クラスと説明
`protected class`	`AbstractReactorMessageHandler.ChannelForwardingSubscriber`

フィールド概要
フィールド
修飾子と型フィールドと説明
protected org.slf4j.Logger logger
protected Processor processor
- クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
  messagingTemplate
- インターフェース org.springframework.core.Ordered から継承されたフィールド
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

フィールド
修飾子と型	フィールドと説明
`protected org.slf4j.Logger`	`logger`
`protected Processor`	`processor`

コンストラクター概要

コンストラクター
コンストラクターと説明
`AbstractReactorMessageHandler(Processor processor)` 処理を委譲するリアクターベースのプロセッサーを指定して、新しい BroadcasterMessageHandler を構築します。

方法の概要

メソッド
修飾子と型	メソッドと説明
`reactor.Environment`	`getEnvironment()` ストリーム処理操作に使用する環境を返します。
`java.lang.Class<?>`	`getInputType()` 処理されるストリームの入力型を返します
`int`	`getRingBufferSize()` RingBuffer のサイズを返す
`int`	`getStopTimeout()` プロセッサーをシャットダウンするときに待機する時間をミリ秒単位で返します
`protected void`	`invokeProcessor(org.springframework.messaging.Message<?> message, reactor.core.processor.RingBufferProcessor<java.lang.Object> reactiveProcessorToUse)`
`void`	`setRingBufferSize(int ringBufferSize)` RingBuffer のサイズは 2 の累乗でなければなりません。
`void`	`setStopTimeout(int stopTimeoutInMillis)` プロセッサーをシャットダウンするときにサブスクライバの onComplete メソッド内のラッチを待機する時間 (ミリ秒)。

クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
getOutputChannel, onInit, produceOutput, sendOutputs, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput

クラス org.springframework.integration.handler.AbstractMessageHandler から継承されたメソッド
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, handleMessageInternal, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

インターフェース org.springframework.beans.factory.DisposableBean から継承されたメソッド
destroy

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

- フィールドの詳細
  - logger
```
protected final org.slf4j.Logger logger
```
  - processor
```
protected final Processor processor
```
- コンストラクターの詳細
  - AbstractReactorMessageHandler
```
public AbstractReactorMessageHandler(Processor processor)
```
    処理を委譲するリアクターベースのプロセッサーを指定して、新しい BroadcasterMessageHandler を構築します。
    パラメーター:
    processor - ストリームベースのリアクタープロセッサー
- メソッドの詳細
  - setStopTimeout
```
public void setStopTimeout(int stopTimeoutInMillis)
```
    プロセッサーをシャットダウンするときにサブスクライバの onComplete メソッド内のラッチを待機する時間 (ミリ秒単位)。デフォルトは 5000 ミリ秒です
    パラメーター:
    stopTimeoutInMillis - プロセッサーをシャットダウンするときに待機する時間。
  - getStopTimeout
```
public int getStopTimeout()
```
    プロセッサーをシャットダウンするときに待機する時間をミリ秒単位で返します
  - setRingBufferSize
```
public void setRingBufferSize(int ringBufferSize)
```
    RingBuffer のサイズは 2 の累乗でなければなりません。デフォルトは 8192 です。
    パラメーター:
    ringBufferSize - RingBuffer のサイズ。
  - getRingBufferSize
```
public int getRingBufferSize()
```
    RingBuffer のサイズを返す
  - getEnvironment
```
public reactor.Environment getEnvironment()
```
    ストリーム処理操作に使用する環境を返します。
  - getInputType
```
public java.lang.Class<?> getInputType()
```
    処理されるストリームの入力型を返します
  - invokeProcessor
```
protected void invokeProcessor(org.springframework.messaging.Message<?> message,
                   reactor.core.processor.RingBufferProcessor<java.lang.Object> reactiveProcessorToUse)
```

クラス AbstractReactorMessageHandler

ネストされたクラスの概要

フィールド概要

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

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

コンストラクター概要

方法の概要

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

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

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

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

インターフェース org.springframework.beans.factory.DisposableBean から継承されたメソッド

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

フィールドの詳細

logger

processor

コンストラクターの詳細

AbstractReactorMessageHandler

メソッドの詳細

setStopTimeout

getStopTimeout

setRingBufferSize

getRingBufferSize

getEnvironment

getInputType

invokeProcessor