BroadcasterMessageHandler (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.xd.reactor.BroadcasterMessageHandler

実装済みのインターフェース一覧:
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
```
public class BroadcasterMessageHandler
extends AbstractReactorMessageHandler
```
Stream に処理を委譲することで、MessageHandler の配信時にアイテムを適応させます。
プロセッサーの outputStream は、メッセージを作成し、それを出力チャネルに送信するために使用されます。入力チャネルと出力チャネルが MessageBus に接続されている場合、onNext の呼び出しを介して入力ストリームに配信されたデータは、メッセージバスのディスパッチャースレッドで呼び出され、出力チャネルにメッセージを送信すると、メッセージバス上の IO 操作が行われます。
実装では、非同期ディスパッチを備えた RingBufferProcessor を使用します。これには、ストリームの状態を、onNext を呼び出すすべての受信ディスパッチャースレッド間で共有できるという利点があります。欠点は、処理と出力チャネルへの送信がディスパッチャースレッドの 1 つでシリアルに実行されることです。
このハンドラーを使用すると、データを処理するときに非常に自然な最初のエクスペリエンスが得られます。たとえば、ストリーム http | react-processor | log があり、reactor-processor が buffer(5) を実行してから単一の値を生成するとします。http ソースに 10 個のメッセージを送信すると、使用されるディスパッチャースレッドの数に関係なく、ログには 2 つのメッセージが生成されます。
プロセッサーから outputStream を返す前に、dispatchOn またはその他のスイッチ (http://projectreactor.io/docs/reference/#streams-multithreading)) を明示的に呼び出すことで、出力チャネルへの送信を行う outputStream サブスクライバが使用するスレッドを変更できます。
複数のストリームにまたがるディスパッチャースレッドでの同時実行には、MultipleBroadcasterMessageHandler を使用します。
すべてのエラー処理はプロセッサー実装の責任です。
作成者:
Mark Pollack, Stephane Malbdini

ネストされたクラスの概要
- クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたネストクラス / インターフェース
  AbstractReactorMessageHandler.ChannelForwardingSubscriber

フィールド概要
- クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたフィールド
  logger, processor
- クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
  messagingTemplate
- インターフェース org.springframework.core.Ordered から継承されたフィールド
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

コンストラクター概要

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

方法の概要
メソッド
修飾子と型メソッドと説明
void destroy()
protected void handleMessageInternal(org.springframework.messaging.Message<?> message)
protected void onInit()
- クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたメソッド
  getEnvironment, getInputType, getRingBufferSize, getStopTimeout, invokeProcessor, setRingBufferSize, setStopTimeout
- クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたメソッド
  getOutputChannel, 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, 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.integration.support.context.NamedComponent から継承されたメソッド
  getComponentName

メソッド
修飾子と型	メソッドと説明
`void`	`destroy()`
`protected void`	`handleMessageInternal(org.springframework.messaging.Message<?> message)`
`protected void`	`onInit()`

- コンストラクターの詳細
  - BroadcasterMessageHandler
```
public BroadcasterMessageHandler(Processor processor)
```
    処理を委譲するリアクターベースのプロセッサーを指定して、新しい BroadcasterMessageHandler を構築します。
    パラメーター:
    processor - ストリームベースのリアクタープロセッサー
- メソッドの詳細
  - handleMessageInternal
```
protected void handleMessageInternal(org.springframework.messaging.Message<?> message)
                              throws java.lang.Exception
```
    次で指定:
    クラス org.springframework.integration.handler.AbstractMessageHandler の handleMessageInternal
    例外:
    java.lang.Exception
  - destroy
```
public void destroy()
             throws java.lang.Exception
```
    例外:
    java.lang.Exception
  - onInit
```
protected void onInit()
               throws java.lang.Exception
```
    オーバーライド:
    クラス org.springframework.integration.handler.AbstractMessageProducingHandler の onInit
    例外:
    java.lang.Exception

クラス BroadcasterMessageHandler

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

クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたネストクラス / インターフェース

フィールド概要

クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたフィールド

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

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

コンストラクター概要

方法の概要

クラス org.springframework.xd.reactor.AbstractReactorMessageHandler から継承されたメソッド

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

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

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

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

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

コンストラクターの詳細

BroadcasterMessageHandler

メソッドの詳細

handleMessageInternal

destroy

onInit