RabbitMessageBus (Spring XD 1.3.2.RELEASE API)

java.lang.Object
- org.springframework.xd.dirt.integration.bus.MessageBusSupport
- - org.springframework.xd.dirt.integration.rabbit.RabbitMessageBus

実装済みのインターフェース一覧:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, MessageBus
```
public class RabbitMessageBus
extends MessageBusSupport
implements org.springframework.beans.factory.DisposableBean
```
RabbitMQ をベースとした MessageBus 実装。
作成者:
Mark Fisher, Gary Russell, Jennifer Hickey, Gunnar Hillert, Ilayaperumal Gopinathan, David Turanski

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

コンストラクター概要

コンストラクター
コンストラクターと説明
`RabbitMessageBus(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.integration.codec.Codec codec)`

方法の概要

メソッド
修飾子と型	メソッドと説明
`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()`
`void`	`doManualAck(java.util.LinkedList<org.springframework.messaging.MessageHeaders> messageHeadersList)` メッセージバスに保存されているメタデータに基づいて手動で確認を実行します。
`boolean`	`isCapable(MessageBus.Capability capability)` バスが機能をサポートしている場合は true を返します。
`protected void`	`onInit()`
`void`	`setAddresses(java.lang.String[] addresses)`
`void`	`setAdminAddresses(java.lang.String[] adminAddresses)`
`void`	`setCompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor compressingPostProcessor)` メッセージを圧縮するには `MessagePostProcessor` を設定します。
`void`	`setDecompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor decompressingPostProcessor)` メッセージを解凍するには `MessagePostProcessor` を設定します。
`void`	`setDefaultAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode defaultAcknowledgeMode)`
`void`	`setDefaultAutoBindDLQ(boolean defaultAutoBindDLQ)`
`void`	`setDefaultChannelTransacted(boolean defaultChannelTransacted)`
`void`	`setDefaultDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDefaultDeliveryMode)`
`void`	`setDefaultDefaultRequeueRejected(boolean defaultDefaultRequeueRejected)`
`void`	`setDefaultMaxConcurrency(int defaultMaxConcurrency)` バスのデフォルトの最大コンシューマーを設定します。consumer.maxConcurrency によって上書きできます。
`void`	`setDefaultPrefetchCount(int defaultPrefetchCount)`
`void`	`setDefaultPrefix(java.lang.String defaultPrefix)`
`void`	`setDefaultReplyHeaderPatterns(java.lang.String[] defaultReplyHeaderPatterns)`
`void`	`setDefaultRepublishToDLQ(boolean defaultRepublishToDLQ)`
`void`	`setDefaultRequestHeaderPatterns(java.lang.String[] defaultRequestHeaderPatterns)`
`void`	`setDefaultTxSize(int defaultTxSize)`
`void`	`setKeyStore(java.lang.String keyStore)`
`void`	`setKeyStorePassphrase(java.lang.String keyStorePassphrase)`
`void`	`setLongStringLimit(int longStringLimit)` LongString ヘッダーの長さの制限を設定します。
`void`	`setNodes(java.lang.String[] nodes)`
`void`	`setPassword(java.lang.String password)`
`void`	`setSslPropertiesLocation(org.springframework.core.io.Resource sslPropertiesLocation)`
`void`	`setTrustStore(java.lang.String trustStore)`
`void`	`setTrustStorePassphrase(java.lang.String trustStorePassphrase)`
`void`	`setUsername(java.lang.String username)`
`void`	`setUseSSL(boolean useSSL)`
`void`	`setVhost(java.lang.String vhost)`
`void`	`unbindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel channel)` 特定の p2p または pub/ サブメッセージコンシューマーのバインドを解除する
`void`	`unbindConsumers(java.lang.String name)` 受信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。

クラス 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, getApplicationContext, getBeanFactory, getIdGenerator, isNamedChannel, serializePayloadIfNecessary, setApplicationContext, setCodec, setDefaultBackOffInitialInterval, setDefaultBackOffMaxInterval, setDefaultBackOffMultiplier, setDefaultBatchBufferLimit, setDefaultBatchingEnabled, setDefaultBatchSize, setDefaultBatchTimeout, setDefaultCompress, setDefaultConcurrency, setDefaultDurableSubscription, setDefaultMaxAttempts, setIntegrationEvaluationContext, setPartitionSelector, stopBindings, unbindProducer, unbindProducers, validateConsumerProperties, validateProducerProperties

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

- コンストラクターの詳細
  - RabbitMessageBus
```
public RabbitMessageBus(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                org.springframework.integration.codec.Codec codec)
```
- メソッドの詳細
  - setDecompressingPostProcessor
```
public void setDecompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor decompressingPostProcessor)
```
    メッセージを解凍するために MessagePostProcessor を設定します。デフォルトは、デフォルトのデリゲートを持つ DelegatingDecompressingPostProcessor です。
    パラメーター:
    decompressingPostProcessor - ポストプロセッサー。
  - setCompressingPostProcessor
```
public void setCompressingPostProcessor(org.springframework.amqp.core.MessagePostProcessor compressingPostProcessor)
```
    メッセージを圧縮するには MessagePostProcessor を設定します。デフォルトは GZipPostProcessor です。
    パラメーター:
    compressingPostProcessor - ポストプロセッサー。
  - setDefaultAcknowledgeMode
```
public void setDefaultAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode defaultAcknowledgeMode)
```
  - setDefaultChannelTransacted
```
public void setDefaultChannelTransacted(boolean defaultChannelTransacted)
```
  - setDefaultDefaultDeliveryMode
```
public void setDefaultDefaultDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode defaultDefaultDeliveryMode)
```
  - setDefaultDefaultRequeueRejected
```
public void setDefaultDefaultRequeueRejected(boolean defaultDefaultRequeueRejected)
```
  - setDefaultMaxConcurrency
```
public void setDefaultMaxConcurrency(int defaultMaxConcurrency)
```
    バスのデフォルトの最大コンシューマーを設定します。consumer.maxConcurrency によって上書きできます。'concurrency' より小さい値は、concurrency と同じになるように強制されます。
    パラメーター:
    defaultMaxConcurrency - デフォルトの最大同時実行数。
  - setDefaultPrefetchCount
```
public void setDefaultPrefetchCount(int defaultPrefetchCount)
```
  - setDefaultTxSize
```
public void setDefaultTxSize(int defaultTxSize)
```
  - setDefaultPrefix
```
public void setDefaultPrefix(java.lang.String defaultPrefix)
```
  - setDefaultRequestHeaderPatterns
```
public void setDefaultRequestHeaderPatterns(java.lang.String[] defaultRequestHeaderPatterns)
```
  - setDefaultReplyHeaderPatterns
```
public void setDefaultReplyHeaderPatterns(java.lang.String[] defaultReplyHeaderPatterns)
```
  - setDefaultAutoBindDLQ
```
public void setDefaultAutoBindDLQ(boolean defaultAutoBindDLQ)
```
  - setDefaultRepublishToDLQ
```
public void setDefaultRepublishToDLQ(boolean defaultRepublishToDLQ)
```
  - setAddresses
```
public void setAddresses(java.lang.String[] addresses)
```
  - setAdminAddresses
```
public void setAdminAddresses(java.lang.String[] adminAddresses)
```
  - setNodes
```
public void setNodes(java.lang.String[] nodes)
```
  - setUsername
```
public void setUsername(java.lang.String username)
```
  - setPassword
```
public void setPassword(java.lang.String password)
```
  - setVhost
```
public void setVhost(java.lang.String vhost)
```
  - setUseSSL
```
public void setUseSSL(boolean useSSL)
```
  - setSslPropertiesLocation
```
public void setSslPropertiesLocation(org.springframework.core.io.Resource sslPropertiesLocation)
```
  - setKeyStore
```
public void setKeyStore(java.lang.String keyStore)
```
  - setKeyStorePassphrase
```
public void setKeyStorePassphrase(java.lang.String keyStorePassphrase)
```
  - setTrustStore
```
public void setTrustStore(java.lang.String trustStore)
```
  - setTrustStorePassphrase
```
public void setTrustStorePassphrase(java.lang.String trustStorePassphrase)
```
  - setLongStringLimit
```
public void setLongStringLimit(int longStringLimit)
```
    Set the limit for the lengths of LongString headers. Headers greater than this length are returned as a DataInputStream which requires user code to read. Spring AMQP currently does not handle these when converting back to BasicProperties.
    パラメーター:
    longStringLimit - 限界 - デフォルトは 8192 です。
  - 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 - バインディングで使用される任意の文字列キー / 値のペア。
  - unbindConsumer
```
public void unbindConsumer(java.lang.String name,
                  org.springframework.messaging.MessageChannel channel)
```
    インターフェースからコピーされた説明: MessageBus
    特定の p2p または pub/ サブメッセージコンシューマーのバインドを解除する
    次で指定:
    インターフェース MessageBus 内の unbindConsumer
    オーバーライド:
    クラス MessageBusSupport の unbindConsumer
    パラメーター:
    name - メッセージソースの論理的な識別
    channel - コンシューマーとしてのチャネル
  - unbindConsumers
```
public void unbindConsumers(java.lang.String name)
```
    インターフェースからコピーされた説明: MessageBus
    受信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。
    次で指定:
    インターフェース MessageBus 内の unbindConsumers
    オーバーライド:
    クラス MessageBusSupport の unbindConsumers
    パラメーター:
    name - チャンネル名
  - isCapable
```
public boolean isCapable(MessageBus.Capability capability)
```
    インターフェースからコピーされた説明: MessageBus
    バスが機能をサポートしている場合は true を返します。
    次で指定:
    インターフェース MessageBus 内の isCapable
    オーバーライド:
    クラス MessageBusSupport の isCapable
    パラメーター:
    capability - 機能。
    戻り値:
    機能がサポートされている場合は true です。
  - destroy
```
public void destroy()
```
    次で指定:
    インターフェース org.springframework.beans.factory.DisposableBean 内の destroy
  - doManualAck
```
public void doManualAck(java.util.LinkedList<org.springframework.messaging.MessageHeaders> messageHeadersList)
```
    クラスからコピーされた説明: MessageBusSupport
    メッセージバスに保存されているメタデータに基づいて手動で確認を実行します。
    オーバーライド:
    クラス MessageBusSupport の doManualAck

クラス RabbitMessageBus

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

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

コンストラクターの詳細

RabbitMessageBus

メソッドの詳細

setDecompressingPostProcessor

setCompressingPostProcessor

setDefaultAcknowledgeMode

setDefaultChannelTransacted

setDefaultDefaultDeliveryMode

setDefaultDefaultRequeueRejected

setDefaultMaxConcurrency

setDefaultPrefetchCount

setDefaultTxSize

setDefaultPrefix

setDefaultRequestHeaderPatterns

setDefaultReplyHeaderPatterns

setDefaultAutoBindDLQ

setDefaultRepublishToDLQ

setAddresses

setAdminAddresses

setNodes

setUsername

setPassword

setVhost

setUseSSL

setSslPropertiesLocation

setKeyStore

setKeyStorePassphrase

setTrustStore

setTrustStorePassphrase

setLongStringLimit

onInit

bindConsumer

bindPubSubConsumer

bindProducer

bindPubSubProducer

bindRequestor

bindReplier

unbindConsumer

unbindConsumers

isCapable

destroy

doManualAck