RedisMessageBus (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.xd.dirt.integration.bus.MessageBusSupport
- - org.springframework.xd.dirt.integration.redis.RedisMessageBus

実装されたすべてのインターフェース:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, MessageBus
```
public class RedisMessageBus
extends MessageBusSupport
implements org.springframework.beans.factory.DisposableBean
```
Redis に基づく MessageBus 実装。
作成者:
Mark Fisher, Gary Russell, David Turanski, Jennifer Hickey

ネストされたクラスのサマリー
- クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたネストクラス / インターフェース
  MessageBusSupport.DirectHandler, MessageBusSupport.PartitioningMetadata, MessageBusSupport.SetBuilder, MessageBusSupport.SharedChannelProvider<T extends org.springframework.messaging.MessageChannel>
- インターフェース org.springframework.xd.dirt.integration.bus.MessageBus から継承されたネストクラス / インターフェース
  MessageBus.Capability

フィールドのサマリー
- クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたフィールド
  CONSUMER_RETRY_PROPERTIES, CONSUMER_STANDARD_PROPERTIES, defaultBackOffInitialInterval, defaultBackOffMaxInterval, defaultBackOffMultiplier, defaultBatchBufferLimit, defaultBatchingEnabled, defaultBatchSize, defaultBatchTimeout, defaultCompress, defaultConcurrency, defaultDurableSubscription, defaultMaxAttempts, directChannelProvider, evaluationContext, JOB_CHANNEL_TYPE_PREFIX, logger, MEDIATYPES_MEDIATYPE_ALL, P2P_NAMED_CHANNEL_TYPE_PREFIX, PARTITION_HEADER, PRODUCER_BATCHING_ADVANCED_PROPERTIES, PRODUCER_BATCHING_BASIC_PROPERTIES, PRODUCER_PARTITIONING_PROPERTIES, PRODUCER_STANDARD_PROPERTIES, PUBSUB_NAMED_CHANNEL_TYPE_PREFIX, TAP_TYPE_PREFIX

コンストラクターの概要

コンストラクター
コンストラクターと説明
`RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.integration.codec.Codec codec)`
`RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.integration.codec.Codec codec, java.lang.String... headersToMap)`

メソッドのサマリー

メソッド
修飾子と型	メソッドと説明
`void`	`bindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel, java.util.Properties properties)` P2P チャネルにメッセージコンシューマーをバインドする
`void`	`bindProducer(java.lang.String name, org.springframework.messaging.MessageChannel moduleOutputChannel, java.util.Properties properties)` メッセージプロデューサーを P2P チャネルにバインドします。
`void`	`bindPubSubConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel, java.util.Properties properties)` pub/ サブチャネルにメッセージコンシューマーをバインドする
`void`	`bindPubSubProducer(java.lang.String name, org.springframework.messaging.MessageChannel moduleOutputChannel, java.util.Properties properties)` pub/ サブチャネルにメッセージプロデューサーをバインドします。
`void`	`bindReplier(java.lang.String name, org.springframework.messaging.MessageChannel requests, org.springframework.messaging.MessageChannel replies, java.util.Properties properties)` リクエスタからのリクエストを処理し、非同期的に応答を送信するコンシューマーをバインドします。
`void`	`bindRequestor(java.lang.String name, org.springframework.messaging.MessageChannel requests, org.springframework.messaging.MessageChannel replies, java.util.Properties properties)` 非同期応答を期待するプロデューサーをバインドします。
`void`	`destroy()`
`protected void`	`onInit()`

クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたメソッド
addBinding, afterPropertiesSet, applyPrefix, applyPubSub, applyRequests, bindDynamicProducer, bindDynamicPubSubProducer, bindExistingProducerDirectlyIfPossible, bindNewProducerDirectlyIfPossible, buildPartitionRoutingExpression, buildRetryTemplateIfRetryEnabled, constructDLQName, deleteBinding, deleteBindings, deserializePayloadIfNecessary, deserializePayloadIfNecessary, determinePartition, doBindDynamicProducer, doBindDynamicPubSubProducer, doManualAck, getApplicationContext, getBeanFactory, getIdGenerator, isCapable, isNamedChannel, serializePayloadIfNecessary, setApplicationContext, setCodec, setDefaultBackOffInitialInterval, setDefaultBackOffMaxInterval, setDefaultBackOffMultiplier, setDefaultBatchBufferLimit, setDefaultBatchingEnabled, setDefaultBatchSize, setDefaultBatchTimeout, setDefaultCompress, setDefaultConcurrency, setDefaultDurableSubscription, setDefaultMaxAttempts, setIntegrationEvaluationContext, setPartitionSelector, stopBindings, unbindConsumer, unbindConsumers, unbindProducer, unbindProducers, validateConsumerProperties, validateProducerProperties

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

- コンストラクターの詳細
  - RedisMessageBus
```
public RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
               org.springframework.integration.codec.Codec codec)
```
  - RedisMessageBus
```
public RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
               org.springframework.integration.codec.Codec codec,
               java.lang.String... headersToMap)
```
- メソッドの詳細
  - onInit
```
protected void onInit()
```
    オーバーライド:
    クラス MessageBusSupport の onInit
  - bindConsumer
```
public void bindConsumer(java.lang.String name,
                org.springframework.messaging.MessageChannel moduleInputChannel,
                java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    P2P チャネルにメッセージコンシューマーをバインドする
    次で指定:
    インターフェース MessageBus の bindConsumer
    パラメーター:
    name - メッセージソースの論理的 ID
    moduleInputChannel - コンシューマーとしてのチャネル
    properties - バインディングで使用される任意の文字列キー / 値のペア
  - bindPubSubConsumer
```
public void bindPubSubConsumer(java.lang.String name,
                      org.springframework.messaging.MessageChannel moduleInputChannel,
                      java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    pub/ サブチャネルにメッセージコンシューマーをバインドする
    次で指定:
    インターフェース MessageBus の bindPubSubConsumer
    パラメーター:
    name - メッセージソースの論理的 ID
    moduleInputChannel - pub/ サブコンシューマーとしてバインドされたチャネル
    properties - バインディングで使用される任意の文字列キー / 値のペア
  - bindProducer
```
public void bindProducer(java.lang.String name,
                org.springframework.messaging.MessageChannel moduleOutputChannel,
                java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    メッセージプロデューサーを P2P チャネルにバインドします。
    次で指定:
    インターフェース MessageBus の bindProducer
    パラメーター:
    name - メッセージターゲットの論理的アイデンティティ
    moduleOutputChannel - プロデューサーとして縛られたチャンネル
    properties - バインディングで使用される任意の文字列キー / 値のペア
  - bindPubSubProducer
```
public void bindPubSubProducer(java.lang.String name,
                      org.springframework.messaging.MessageChannel moduleOutputChannel,
                      java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    pub/ サブチャネルにメッセージプロデューサーをバインドします。
    次で指定:
    インターフェース MessageBus の bindPubSubProducer
    パラメーター:
    name - メッセージターゲットの論理的アイデンティティ
    moduleOutputChannel - プロデューサーとして縛られたチャンネル
    properties - バインディングで使用される任意の文字列キー / 値のペア
  - bindRequestor
```
public void bindRequestor(java.lang.String name,
                 org.springframework.messaging.MessageChannel requests,
                 org.springframework.messaging.MessageChannel replies,
                 java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    非同期応答を期待するプロデューサーをバインドします。バインドを解除するには、unbindProducer() と unbindConsumer() を呼び出します。
    次で指定:
    インターフェース MessageBus の bindRequestor
    パラメーター:
    name - リクエスト者の名前。
    requests - リクエストチャネル - リクエストを送信します。
    replies - 返信チャンネル - 返信を受け取ります。
    properties - バインディングで使用される任意の文字列キー / 値のペア。
  - bindReplier
```
public void bindReplier(java.lang.String name,
               org.springframework.messaging.MessageChannel requests,
               org.springframework.messaging.MessageChannel replies,
               java.util.Properties properties)
```
    インターフェースからコピーされた説明: MessageBus
    リクエスタからのリクエストを処理し、非同期的に応答を送信するコンシューマーをバインドします。バインドを解除するには、unbindProducer() と unbindConsumer() を呼び出します。
    次で指定:
    インターフェース MessageBus の bindReplier
    パラメーター:
    name - このリプライヤがリクエストを処理するリクエスタの名前。
    requests - リクエストチャネル - リクエストを受け取ります。
    replies - 返信チャンネル - 返信を送信します。
    properties - バインディングで使用される任意の文字列キー / 値のペア。
  - destroy
```
public void destroy()
```
    次で指定:
    インターフェース org.springframework.beans.factory.DisposableBean の destroy

クラス RedisMessageBus

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

クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたネストクラス / インターフェース

インターフェース org.springframework.xd.dirt.integration.bus.MessageBus から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.xd.dirt.integration.bus.MessageBusSupport から継承されたメソッド

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

コンストラクターの詳細

RedisMessageBus

RedisMessageBus

メソッドの詳細

onInit

bindConsumer

bindPubSubConsumer

bindProducer

bindPubSubProducer

bindRequestor

bindReplier

destroy