MultipleBroadcasterMessageHandler (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.MultipleBroadcasterMessageHandler

実装済みのインターフェース一覧:
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 MultipleBroadcasterMessageHandler
extends AbstractReactorMessageHandler
```
partitionExpression に基づいてストリームに処理を委譲することにより、MessageHandler のアイテムを一度に配信するように適応します。
メッセージが委譲される特定のストリームは、partitionExpression 値によって決定されます。プロセッサーで inputStream のスケジュールを変更しない限り、partitionExpression が異なるメッセージバスディスパッチャースレッドで配信されたメッセージを同じストリームにマップしないようにする必要があります。これは、基盤となる Broadcaster の使用によるものです。
たとえば、式 T(java.lang.Thread).currentThread().getId() を使用すると、現在のディスパッチャースレッド ID が Stream のインスタンスにマップされます。Kafka パーティションごとに Stream が必要な場合は、MessageBus ディスパッチャースレッドが各パーティションで同じになるため、式 header['kafka_partition_id'] を使用できます。
partitionExpression 値にマップされたストリームにエラーがある場合、または完了した場合は、次に消費されるメッセージが同じ partitionExpression 値にマップされたときに再作成されます。
すべてのエラー処理はプロセッサー実装の責任です。
作成者:
Mark Pollack, Stephane Maldini, Gary Russell

ネストされたクラスの概要
- クラス 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

コンストラクター概要

コンストラクター
コンストラクターと説明
`MultipleBroadcasterMessageHandler(Processor processor, java.lang.String partitionExpression)` 処理を委譲するリアクターベースのプロセッサーとパーティション式を指定して、新しい MessageHandler を構築します。

方法の概要

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

クラス 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

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

クラス MultipleBroadcasterMessageHandler

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

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

コンストラクターの詳細

MultipleBroadcasterMessageHandler

メソッドの詳細

setIntegrationEvaluationContext

onInit

handleMessageInternal

destroy