SubjectMessageHandler (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.rxjava.SubjectMessageHandler

実装されているすべてのインターフェース:
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 SubjectMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
implements org.springframework.beans.factory.DisposableBean
```
Observable に処理を委譲することで、MessageHandler のアイテムを一度に配信するように調整します。
プロセッサーの outputStream は、メッセージを作成し、それを出力チャネルに送信するために使用されます。入力チャネルと出力チャネルが MessageBus に接続されている場合、onNext の呼び出しを介して入力ストリームに配信されたデータは、メッセージバスのディスパッチャースレッドで呼び出され、出力チャネルにメッセージを送信すると、メッセージバス上の IO 操作が行われます。
実装では SerializedSubject を使用します。これには、Observabale の状態を、onNext を呼び出すすべての受信ディスパッチャースレッド間で共有できるという利点があります。欠点は、処理と出力チャネルへの送信がディスパッチャースレッドの 1 つでシリアルに実行されることです。
このハンドラーを使用すると、データを処理するときに非常に自然な最初のエクスペリエンスが得られます。たとえば、ストリーム http | rxjava-processor | log があり、rxjava-processor が buffer(5) を実行してから単一の値を生成するとします。http ソースに 10 個のメッセージを送信すると、使用されるディスパッチャースレッドの数に関係なく、ログには 2 つのメッセージが生成されます。
プロセッサーから outputStream を返す前に observeOn を明示的に呼び出すことで、出力チャネルへの送信を行う outputStream サブスクライバーが使用するスレッドを変更できます。
複数の Observable にまたがるディスパッチャースレッドでの同時実行には、MultipleSubjectMessageHandler を使用します。すべてのエラー処理はプロセッサー実装の責任です。
作成者:
Mark Pollack

- フィールドのサマリー
  フィールド
  修飾子と型フィールドと説明
  protected org.slf4j.Logger logger
  - クラス org.springframework.integration.handler.AbstractMessageProducingHandler から継承されたフィールド
    messagingTemplate
  - インターフェース org.springframework.core.Ordered から継承されたフィールド
    HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
- コンストラクターの概要
  コンストラクター
  コンストラクターと説明
  SubjectMessageHandler(Processor processor)
- メソッドのサマリー
  メソッド
  修飾子と型メソッドと説明
  void destroy()
  protected void handleMessageInternal(org.springframework.messaging.Message<?> message)
  - クラス 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, 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

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

コンストラクター
コンストラクターと説明
`SubjectMessageHandler(Processor processor)`

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

- フィールドの詳細
  - logger
```
protected final org.slf4j.Logger logger
```
- コンストラクターの詳細
  - SubjectMessageHandler
```
public SubjectMessageHandler(Processor 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
```
    次で指定:
    インターフェース org.springframework.beans.factory.DisposableBean の destroy
    例外:
    java.lang.Exception

クラス SubjectMessageHandler

フィールドのサマリー

クラス 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.integration.support.context.NamedComponent から継承されたメソッド

フィールドの詳細

logger

コンストラクターの詳細

SubjectMessageHandler

メソッドの詳細

handleMessageInternal

destroy