MessageBusSupport (Spring XD 1.3.2.RELEASE API)

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

実装済みのインターフェース一覧:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, MessageBus
既知の直属サブクラス
KafkaMessageBus, LocalMessageBus, RabbitMessageBus, RedisMessageBus
```
public abstract class MessageBusSupport
extends java.lang.Object
implements MessageBus, org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean
```
作成者:
David Turanski, Gary Russell, Ilayaperumal Gopinathan

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

ネストされたクラス
修飾子と型	クラスと説明
`static class`	`MessageBusSupport.DirectHandler`
`protected static class`	`MessageBusSupport.PartitioningMetadata`
`static class`	`MessageBusSupport.SetBuilder`
`protected class`	`MessageBusSupport.SharedChannelProvider<T extends org.springframework.messaging.MessageChannel>` 使用する新しいチャネルを検索するか、オプションで作成します。

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

フィールド概要

フィールド
修飾子と型	フィールドと説明
`protected static java.util.Set<java.lang.Object>`	`CONSUMER_RETRY_PROPERTIES`
`protected static java.util.Set<java.lang.Object>`	`CONSUMER_STANDARD_PROPERTIES` すべてのバス実装がサポートする必要がある (または少なくとも許容する必要がある) プロパティのセット。
`protected long`	`defaultBackOffInitialInterval`
`protected long`	`defaultBackOffMaxInterval`
`protected double`	`defaultBackOffMultiplier`
`protected int`	`defaultBatchBufferLimit`
`protected boolean`	`defaultBatchingEnabled`
`protected int`	`defaultBatchSize`
`protected long`	`defaultBatchTimeout`
`protected boolean`	`defaultCompress`
`protected int`	`defaultConcurrency`
`protected boolean`	`defaultDurableSubscription`
`protected int`	`defaultMaxAttempts`
`protected MessageBusSupport.SharedChannelProvider<org.springframework.integration.channel.DirectChannel>`	`directChannelProvider` バインディングにエイリアス名が含まれない標準的なケースで使用されます。
`protected org.springframework.expression.EvaluationContext`	`evaluationContext`
`protected static java.lang.String`	`JOB_CHANNEL_TYPE_PREFIX`
`protected org.slf4j.Logger`	`logger`
`protected static java.util.List<org.springframework.util.MimeType>`	`MEDIATYPES_MEDIATYPE_ALL`
`protected static java.lang.String`	`P2P_NAMED_CHANNEL_TYPE_PREFIX`
`protected static java.lang.String`	`PARTITION_HEADER`
`protected static java.util.Set<java.lang.Object>`	`PRODUCER_BATCHING_ADVANCED_PROPERTIES`
`protected static java.util.Set<java.lang.Object>`	`PRODUCER_BATCHING_BASIC_PROPERTIES`
`protected static java.util.Set<java.lang.Object>`	`PRODUCER_PARTITIONING_PROPERTIES`
`protected static java.util.Set<java.lang.Object>`	`PRODUCER_STANDARD_PROPERTIES`
`protected static java.lang.String`	`PUBSUB_NAMED_CHANNEL_TYPE_PREFIX`
`protected static java.lang.String`	`TAP_TYPE_PREFIX`

コンストラクター概要
コンストラクター
コンストラクターと説明
MessageBusSupport()

コンストラクター
コンストラクターと説明
`MessageBusSupport()`

方法の概要

メソッド
修飾子と型	メソッドと説明
`protected void`	`addBinding(Binding binding)`
`void`	`afterPropertiesSet()`
`static java.lang.String`	`applyPrefix(java.lang.String prefix, java.lang.String name)` プレフィックスをサポートするバス実装の場合は、名前にプレフィックスを適用します。
`static java.lang.String`	`applyPubSub(java.lang.String name)` 識別子に pub/ サブコンポーネントを含むバス実装の場合は、名前を構築します。
`static java.lang.String`	`applyRequests(java.lang.String name)` リクエストのエンティティ名を構築します。
`org.springframework.messaging.MessageChannel`	`bindDynamicProducer(java.lang.String name, java.util.Properties properties)` 指定されたチャネルのプロデューサーを動的に作成します。
`org.springframework.messaging.MessageChannel`	`bindDynamicPubSubProducer(java.lang.String name, java.util.Properties properties)` 指定されたチャネルのプロデューサーを動的に作成します。
`protected void`	`bindExistingProducerDirectlyIfPossible(java.lang.String name, org.springframework.messaging.MessageChannel consumerChannel)` ローカルプロデューサーがすでに存在する場合は、バスを回避してプロデューサーを直接バインドしようとします。
`protected boolean`	`bindNewProducerDirectlyIfPossible(java.lang.String name, org.springframework.messaging.SubscribableChannel moduleOutputChannel, AbstractBusPropertiesAccessor properties)` コンシューマーがローカルの場合、直接バインディング (バスを回避) の作成を試みます。
`protected java.lang.String`	`buildPartitionRoutingExpression(java.lang.String expressionRoot)`
`protected org.springframework.retry.support.RetryTemplate`	`buildRetryTemplateIfRetryEnabled(AbstractBusPropertiesAccessor properties)` コンシューマーの "maxAttempts" プロパティが設定されている場合は、再試行テンプレートを作成して構成します。
`static java.lang.String`	`constructDLQName(java.lang.String name)` デッドレターをサポートするバス実装の場合は、基になるパイプ名のデッドレターエンティティの名前を構築します。
`protected void`	`deleteBinding(java.lang.String name, org.springframework.messaging.MessageChannel channel)`
`protected void`	`deleteBindings(java.lang.String name)`
`protected MessageValues`	`deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)`
`protected MessageValues`	`deserializePayloadIfNecessary(MessageValues message)`
`protected int`	`determinePartition(org.springframework.messaging.Message<?> message, MessageBusSupport.PartitioningMetadata meta)` このメッセージを送信するパーティションを決定します。
`protected org.springframework.messaging.MessageChannel`	`doBindDynamicProducer(java.lang.String name, java.lang.String channelName, java.util.Properties properties)` 名前付きチャネルのプロデューサーを作成し、それをバスにバインドします。
`protected org.springframework.messaging.MessageChannel`	`doBindDynamicPubSubProducer(java.lang.String name, java.lang.String channelName, java.util.Properties properties)` 名前付きチャネルのプロデューサーを作成し、それをバスにバインドします。
`void`	`doManualAck(java.util.LinkedList<org.springframework.messaging.MessageHeaders> messageHeaders)` メッセージバスに保存されているメタデータに基づいて手動で確認を実行します。
`protected org.springframework.context.support.AbstractApplicationContext`	`getApplicationContext()`
`protected org.springframework.beans.factory.config.ConfigurableListableBeanFactory`	`getBeanFactory()`
`protected org.springframework.util.IdGenerator`	`getIdGenerator()`
`boolean`	`isCapable(MessageBus.Capability capability)` バスが機能をサポートしている場合は true を返します。
`protected boolean`	`isNamedChannel(java.lang.String name)`
`protected void`	`onInit()`
`protected MessageValues`	`serializePayloadIfNecessary(org.springframework.messaging.Message<?> message)`
`void`	`setApplicationContext(org.springframework.context.ApplicationContext applicationContext)`
`void`	`setCodec(org.springframework.integration.codec.Codec codec)`
`void`	`setDefaultBackOffInitialInterval(long defaultBackOffInitialInterval)` このバスのデフォルトの再試行オフ初期間隔を設定します。コンシューマーの "backOffInitialInterval" プロパティで上書きできます。
`void`	`setDefaultBackOffMaxInterval(long defaultBackOffMaxInterval)` このバスのデフォルトの再試行バックオフ最大間隔を設定します。コンシューマーの "backOffMaxInterval" プロパティで上書きできます。
`void`	`setDefaultBackOffMultiplier(double defaultBackOffMultiplier)` このバスのデフォルトの再試行バックオフ乗数を設定します。コンシューマーの "backOffMultiplier" プロパティで上書きできます。
`void`	`setDefaultBatchBufferLimit(int defaultBatchBufferLimit)` デフォルトのバッチバッファ制限を設定します。バッチのサイズがこの制限を超える場合にバッチを早期に送信するために使用されます。
`void`	`setDefaultBatchingEnabled(boolean defaultBatchingEnabled)` このバスがデフォルトでメッセージ送信をバッチ処理するかどうかを設定します。
`void`	`setDefaultBatchSize(int defaultBatchSize)` デフォルトのバッチサイズを設定します。バッチ処理が有効になっていて、バスがバッチ処理をサポートしている場合にのみ適用されます。
`void`	`setDefaultBatchTimeout(long defaultBatchTimeout)` デフォルトのバッチタイムアウトを設定します。この時間内にメッセージが到着しない場合にバッチを送信するために使用されます。
`void`	`setDefaultCompress(boolean defaultCompress)` プロデューサーがデフォルトで圧縮を使用するかどうかを設定します。
`void`	`setDefaultConcurrency(int defaultConcurrency)` このバスのデフォルトの同時実行性を設定します。コンシューマーの「同時実行性」プロパティで上書きできます。
`void`	`setDefaultDurableSubscription(boolean defaultDurableSubscription)` タップ / トピックへのサブスクリプションが永続的かどうかを設定します。
`void`	`setDefaultMaxAttempts(int defaultMaxAttempts)` このバスのデフォルトの最大配信試行回数。
`void`	`setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)`
`void`	`setPartitionSelector(PartitionSelectorStrategy partitionSelector)` モジュールに partitionExpression が提供されていない場合は、このバスで使用されるパーティション戦略を設定します。
`protected void`	`stopBindings()`
`void`	`unbindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel channel)` 特定の p2p または pub/ サブメッセージコンシューマーのバインドを解除する
`void`	`unbindConsumers(java.lang.String name)` 受信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。
`void`	`unbindProducer(java.lang.String name, org.springframework.messaging.MessageChannel channel)` 特定の p2p または pub/sub メッセージプロデューサーのバインドを解除する
`void`	`unbindProducers(java.lang.String name)` 送信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。
`protected void`	`validateConsumerProperties(java.lang.String name, java.util.Properties properties, java.util.Set<java.lang.Object> supported)` コンシューマーに提供されたデプロイプロパティを、このバス実装でサポートされているプロパティと照合して検証します。
`protected void`	`validateProducerProperties(java.lang.String name, java.util.Properties properties, java.util.Set<java.lang.Object> supported)` 提供されたプロデューサーのデプロイプロパティを、このバス実装でサポートされているプロパティと照合して検証します。

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

インターフェース org.springframework.xd.dirt.integration.bus.MessageBus から継承されたメソッド
bindConsumer, bindProducer, bindPubSubConsumer, bindPubSubProducer, bindReplier, bindRequestor

- フィールドの詳細
  - P2P_NAMED_CHANNEL_TYPE_PREFIX
```
protected static final java.lang.String P2P_NAMED_CHANNEL_TYPE_PREFIX
```
    関連事項:
    定数フィールド値
  - TAP_TYPE_PREFIX
```
protected static final java.lang.String TAP_TYPE_PREFIX
```
    関連事項:
    定数フィールド値
  - PUBSUB_NAMED_CHANNEL_TYPE_PREFIX
```
protected static final java.lang.String PUBSUB_NAMED_CHANNEL_TYPE_PREFIX
```
    関連事項:
    定数フィールド値
  - JOB_CHANNEL_TYPE_PREFIX
```
protected static final java.lang.String JOB_CHANNEL_TYPE_PREFIX
```
    関連事項:
    定数フィールド値
  - PARTITION_HEADER
```
protected static final java.lang.String PARTITION_HEADER
```
    関連事項:
    定数フィールド値
  - logger
```
protected final org.slf4j.Logger logger
```
  - MEDIATYPES_MEDIATYPE_ALL
```
protected static final java.util.List<org.springframework.util.MimeType> MEDIATYPES_MEDIATYPE_ALL
```
  - CONSUMER_STANDARD_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> CONSUMER_STANDARD_PROPERTIES
```
    すべてのバス実装がサポートする必要がある (または少なくとも許容する必要がある) プロパティのセット。
  - PRODUCER_STANDARD_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> PRODUCER_STANDARD_PROPERTIES
```
  - CONSUMER_RETRY_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> CONSUMER_RETRY_PROPERTIES
```
  - PRODUCER_PARTITIONING_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> PRODUCER_PARTITIONING_PROPERTIES
```
  - PRODUCER_BATCHING_BASIC_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> PRODUCER_BATCHING_BASIC_PROPERTIES
```
  - PRODUCER_BATCHING_ADVANCED_PROPERTIES
```
protected static final java.util.Set<java.lang.Object> PRODUCER_BATCHING_ADVANCED_PROPERTIES
```
  - evaluationContext
```
protected volatile org.springframework.expression.EvaluationContext evaluationContext
```
  - directChannelProvider
```
protected final MessageBusSupport.SharedChannelProvider<org.springframework.integration.channel.DirectChannel> directChannelProvider
```
    バインディングにエイリアス名が含まれない標準的なケースで使用されます。
  - defaultBackOffInitialInterval
```
protected volatile long defaultBackOffInitialInterval
```
  - defaultBackOffMaxInterval
```
protected volatile long defaultBackOffMaxInterval
```
  - defaultBackOffMultiplier
```
protected volatile double defaultBackOffMultiplier
```
  - defaultConcurrency
```
protected volatile int defaultConcurrency
```
  - defaultMaxAttempts
```
protected volatile int defaultMaxAttempts
```
  - defaultBatchingEnabled
```
protected volatile boolean defaultBatchingEnabled
```
  - defaultBatchSize
```
protected volatile int defaultBatchSize
```
  - defaultBatchBufferLimit
```
protected volatile int defaultBatchBufferLimit
```
  - defaultBatchTimeout
```
protected volatile long defaultBatchTimeout
```
  - defaultCompress
```
protected volatile boolean defaultCompress
```
  - defaultDurableSubscription
```
protected volatile boolean defaultDurableSubscription
```
- コンストラクターの詳細
  - MessageBusSupport
```
public MessageBusSupport()
```
- メソッドの詳細
  - applyPrefix
```
public static java.lang.String applyPrefix(java.lang.String prefix,
                           java.lang.String name)
```
    プレフィックスをサポートするバス実装の場合は、名前にプレフィックスを適用します。
    パラメーター:
    prefix - プレフィックス。
    name - 名前。
  - applyPubSub
```
public static java.lang.String applyPubSub(java.lang.String name)
```
    識別子に pub/ サブコンポーネントを含むバス実装の場合は、名前を構築します。
    パラメーター:
    name - 名前。
  - applyRequests
```
public static java.lang.String applyRequests(java.lang.String name)
```
    リクエストのエンティティ名を構築します。
    パラメーター:
    name - 名前。
    戻り値:
    リクエストエンティティ名。
  - constructDLQName
```
public static java.lang.String constructDLQName(java.lang.String name)
```
    デッドレターをサポートするバス実装の場合は、基になるパイプ名のデッドレターエンティティの名前を構築します。
    パラメーター:
    name - 名前。
  - setApplicationContext
```
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException
```
    次で指定:
    インターフェース org.springframework.context.ApplicationContextAware 内の setApplicationContext
    例外:
    org.springframework.beans.BeansException
  - getApplicationContext
```
protected org.springframework.context.support.AbstractApplicationContext getApplicationContext()
```
  - getBeanFactory
```
protected org.springframework.beans.factory.config.ConfigurableListableBeanFactory getBeanFactory()
```
  - setCodec
```
public void setCodec(org.springframework.integration.codec.Codec codec)
```
  - getIdGenerator
```
protected org.springframework.util.IdGenerator getIdGenerator()
```
  - setIntegrationEvaluationContext
```
public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)
```
  - setPartitionSelector
```
public void setPartitionSelector(PartitionSelectorStrategy partitionSelector)
```
    モジュールに partitionExpression が提供されていない場合は、このバスで使用されるパーティション戦略を設定します。
    パラメーター:
    partitionSelector - セレクタ。
  - setDefaultBackOffInitialInterval
```
public void setDefaultBackOffInitialInterval(long defaultBackOffInitialInterval)
```
    このバスのデフォルトの再試行オフ初期間隔を設定します。コンシューマーの "backOffInitialInterval" プロパティで上書きできます。
    パラメーター:
    defaultBackOffInitialInterval -
  - setDefaultBackOffMultiplier
```
public void setDefaultBackOffMultiplier(double defaultBackOffMultiplier)
```
    このバスのデフォルトの再試行バックオフ乗数を設定します。コンシューマーの "backOffMultiplier" プロパティで上書きできます。
    パラメーター:
    defaultBackOffMultiplier -
  - setDefaultBackOffMaxInterval
```
public void setDefaultBackOffMaxInterval(long defaultBackOffMaxInterval)
```
    このバスのデフォルトの再試行バックオフ最大間隔を設定します。コンシューマーの "backOffMaxInterval" プロパティで上書きできます。
    パラメーター:
    defaultBackOffMaxInterval -
  - setDefaultConcurrency
```
public void setDefaultConcurrency(int defaultConcurrency)
```
    このバスのデフォルトの同時実行性を設定します。コンシューマーの「同時実行性」プロパティで上書きできます。
    パラメーター:
    defaultConcurrency -
  - setDefaultMaxAttempts
```
public void setDefaultMaxAttempts(int defaultMaxAttempts)
```
    このバスのデフォルトの最大配信試行回数。サポートされている場合は、コンシューマープロパティ "maxAttempts" で上書きできます。2 未満の値を指定すると再試行が無効になり、1 回の配信試行が行われます。
    パラメーター:
    defaultMaxAttempts - デフォルトの最大試行回数。
  - setDefaultBatchingEnabled
```
public void setDefaultBatchingEnabled(boolean defaultBatchingEnabled)
```
    このバスがデフォルトでメッセージ送信をバッチ処理するかどうかを設定します。バッチ処理をサポートするバス実装にのみ適用されます。
    パラメーター:
    defaultBatchingEnabled - defaultBatchingEnabled を設定します。
  - setDefaultBatchSize
```
public void setDefaultBatchSize(int defaultBatchSize)
```
    デフォルトのバッチサイズを設定します。バッチ処理が有効になっていて、バスがバッチ処理をサポートしている場合にのみ適用されます。
    パラメーター:
    defaultBatchSize - defaultBatchSize を設定します。
  - setDefaultBatchBufferLimit
```
public void setDefaultBatchBufferLimit(int defaultBatchBufferLimit)
```
    バッチバッファのデフォルト制限を設定します。この制限を超えると、バッチが早期に送信されます。バッチ処理が有効で、バスがこのプロパティをサポートしている場合にのみ適用されます。
    パラメーター:
    defaultBatchBufferLimit - defaultBatchBufferLimit を設定します。
  - setDefaultBatchTimeout
```
public void setDefaultBatchTimeout(long defaultBatchTimeout)
```
    バッチ処理のデフォルトタイムアウトを設定します。このタイムアウト時間内にメッセージが届かない場合に、バッチを送信するために使用されます。バッチ処理が有効になっており、バスがこのプロパティをサポートしている場合にのみ適用されます。
    パラメーター:
    defaultBatchTimeout - defaultBatchTimeout を設定します。
  - setDefaultCompress
```
public void setDefaultCompress(boolean defaultCompress)
```
    プロデューサーがデフォルトで圧縮を使用するかどうかを設定します。
    パラメーター:
    defaultCompress - 圧縮を使用するには "true" を選択します。
  - setDefaultDurableSubscription
```
public void setDefaultDurableSubscription(boolean defaultDurableSubscription)
```
    タップ / トピックへのサブスクリプションが永続的かどうかを設定します。
    パラメーター:
    defaultDurableSubscription - 耐久性がある場合は true（デフォルトは false）。
  - afterPropertiesSet
```
public void afterPropertiesSet()
                        throws java.lang.Exception
```
    次で指定:
    インターフェース org.springframework.beans.factory.InitializingBean 内の afterPropertiesSet
    例外:
    java.lang.Exception
  - onInit
```
protected void onInit()
```
  - bindDynamicProducer
```
public org.springframework.messaging.MessageChannel bindDynamicProducer(java.lang.String name,
                                                               java.util.Properties properties)
```
    指定されたチャネルのプロデューサーを動的に作成します。
    次で指定:
    インターフェース MessageBus 内の bindDynamicProducer
    パラメーター:
    name - 名前。
    properties - プロパティ。
    戻り値:
    チャンネル。
  - doBindDynamicProducer
```
protected org.springframework.messaging.MessageChannel doBindDynamicProducer(java.lang.String name,
                                                                 java.lang.String channelName,
                                                                 java.util.Properties properties)
```
    指定されたチャネルのプロデューサーを作成し、バスにバインドします。複数のインスタンスが作成されないように同期処理を行います。
    パラメーター:
    name - 名前。
    channelName - The name of the channel to be created, and registered as bean.
    properties - プロパティ。
    戻り値:
    チャンネル。
  - bindDynamicPubSubProducer
```
public org.springframework.messaging.MessageChannel bindDynamicPubSubProducer(java.lang.String name,
                                                                     java.util.Properties properties)
```
    Dynamically create a producer for the named channel. Note: even though it's pub/sub, we still use a direct channel. It will be bridged to a pub/sub channel in the local bus and bound to an appropriate element for other buses.
    次で指定:
    インターフェース MessageBus 内の bindDynamicPubSubProducer
    パラメーター:
    name - 名前。
    properties - プロパティ。
    戻り値:
    チャンネル。
  - doBindDynamicPubSubProducer
```
protected org.springframework.messaging.MessageChannel doBindDynamicPubSubProducer(java.lang.String name,
                                                                       java.lang.String channelName,
                                                                       java.util.Properties properties)
```
    指定されたチャネルのプロデューサーを作成し、バスにバインドします。複数のインスタンスが作成されないように同期処理を行います。
    パラメーター:
    name - 名前。
    channelName - The name of the channel to be created, and registered as bean.
    properties - プロパティ。
    戻り値:
    チャンネル。
  - unbindConsumers
```
public void unbindConsumers(java.lang.String name)
```
    インターフェースからコピーされた説明: MessageBus
    受信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。
    次で指定:
    インターフェース MessageBus 内の unbindConsumers
    パラメーター:
    name - チャンネル名
  - unbindProducers
```
public void unbindProducers(java.lang.String name)
```
    インターフェースからコピーされた説明: MessageBus
    送信モジュール間チャネルのバインドを解除し、そのチャネルを使用するアクティブなコンポーネントを停止します。
    次で指定:
    インターフェース MessageBus 内の unbindProducers
    パラメーター:
    name - チャンネル名
  - unbindConsumer
```
public void unbindConsumer(java.lang.String name,
                  org.springframework.messaging.MessageChannel channel)
```
    インターフェースからコピーされた説明: MessageBus
    特定の p2p または pub/ サブメッセージコンシューマーのバインドを解除する
    次で指定:
    インターフェース MessageBus 内の unbindConsumer
    パラメーター:
    name - メッセージソースの論理的な識別
    channel - コンシューマーとしてのチャネル
  - unbindProducer
```
public void unbindProducer(java.lang.String name,
                  org.springframework.messaging.MessageChannel channel)
```
    インターフェースからコピーされた説明: MessageBus
    特定の p2p または pub/sub メッセージプロデューサーのバインドを解除する
    次で指定:
    インターフェース MessageBus 内の unbindProducer
    パラメーター:
    name - メッセージターゲットの論理的アイデンティティ
    channel - プロデューサーとして縛られたチャンネル
  - isCapable
```
public boolean isCapable(MessageBus.Capability capability)
```
    インターフェースからコピーされた説明: MessageBus
    バスが機能をサポートしている場合は true を返します。
    次で指定:
    インターフェース MessageBus 内の isCapable
    パラメーター:
    capability - 機能。
    戻り値:
    機能がサポートされている場合は true です。
  - addBinding
```
protected void addBinding(Binding binding)
```
  - deleteBindings
```
protected void deleteBindings(java.lang.String name)
```
  - deleteBinding
```
protected void deleteBinding(java.lang.String name,
                 org.springframework.messaging.MessageChannel channel)
```
  - stopBindings
```
protected void stopBindings()
```
  - serializePayloadIfNecessary
```
protected final MessageValues serializePayloadIfNecessary(org.springframework.messaging.Message<?> message)
```
  - deserializePayloadIfNecessary
```
protected final MessageValues deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)
```
  - deserializePayloadIfNecessary
```
protected final MessageValues deserializePayloadIfNecessary(MessageValues message)
```
  - determinePartition
```
protected int determinePartition(org.springframework.messaging.Message<?> message,
                     MessageBusSupport.PartitioningMetadata meta)
```
    Determine the partition to which to send this message. If a partition key extractor class is provided, it is invoked to determine the key. Otherwise, the partition key expression is evaluated to obtain the key value. If a partition selector class is provided, it will be invoked to determine the partition. Otherwise, if the partition expression is not null, it is evaluated against the key and is expected to return an integer to which the modulo function will be applied, using the partitionCount as the divisor. If no partition expression is provided, the key will be passed to the bus partition strategy along with the partitionCount. The default partition strategy uses key.hashCode(), and the result will be the mod of that value.
    パラメーター:
    message - メッセージ。
    meta - the partitioning metadata.
    戻り値:
    パーティション。
  - validateConsumerProperties
```
protected void validateConsumerProperties(java.lang.String name,
                              java.util.Properties properties,
                              java.util.Set<java.lang.Object> supported)
```
    Validate the provided deployment properties for the consumer against those supported by this bus implementation. The consumer is that part of the bus that consumes messages from the underlying infrastructure and sends them to the next module. Consumer properties are used to configure the consumer.
    パラメーター:
    name - 名前。
    properties - プロパティ。
    supported - The supported properties.
  - validateProducerProperties
```
protected void validateProducerProperties(java.lang.String name,
                              java.util.Properties properties,
                              java.util.Set<java.lang.Object> supported)
```
    Validate the provided deployment properties for the producer against those supported by this bus implementation. When a module sends a message to the bus, the producer uses these properties while sending it to the underlying infrastructure.
    パラメーター:
    name - 名前。
    properties - プロパティ。
    supported - The supported properties.
  - buildPartitionRoutingExpression
```
protected java.lang.String buildPartitionRoutingExpression(java.lang.String expressionRoot)
```
  - buildRetryTemplateIfRetryEnabled
```
protected org.springframework.retry.support.RetryTemplate buildRetryTemplateIfRetryEnabled(AbstractBusPropertiesAccessor properties)
```
    コンシューマーの "maxAttempts" プロパティが設定されている場合は、再試行テンプレートを作成して構成します。
    パラメーター:
    properties - プロパティ。
    戻り値:
    The retry template, or null if retry is not enabled.
  - isNamedChannel
```
protected boolean isNamedChannel(java.lang.String name)
```
  - bindNewProducerDirectlyIfPossible
```
protected boolean bindNewProducerDirectlyIfPossible(java.lang.String name,
                                        org.springframework.messaging.SubscribableChannel moduleOutputChannel,
                                        AbstractBusPropertiesAccessor properties)
```
    Attempt to create a direct binding (avoiding the bus) if the consumer is local. Named channel producers are not bound directly.
    パラメーター:
    name - 名前。
    moduleOutputChannel - The channel to bind.
    properties - The producer properties.
    戻り値:
    true if the producer is bound.
  - bindExistingProducerDirectlyIfPossible
```
protected void bindExistingProducerDirectlyIfPossible(java.lang.String name,
                                          org.springframework.messaging.MessageChannel consumerChannel)
```
    Attempt to bind a producer directly (avoiding the bus) if there is already a local producer. PubSub producers cannot be bound directly. Create the direct binding, then unbind the existing bus producer.
    パラメーター:
    name - 名前。
    consumerChannel - The channel to bind the producer to.
  - doManualAck
```
public void doManualAck(java.util.LinkedList<org.springframework.messaging.MessageHeaders> messageHeaders)
```
    メッセージバスに保存されているメタデータに基づいて手動で確認を実行します。

クラス MessageBusSupport

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

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

フィールド概要

コンストラクター概要

方法の概要

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

インターフェース org.springframework.xd.dirt.integration.bus.MessageBus から継承されたメソッド

フィールドの詳細

P2P_NAMED_CHANNEL_TYPE_PREFIX

TAP_TYPE_PREFIX

PUBSUB_NAMED_CHANNEL_TYPE_PREFIX

JOB_CHANNEL_TYPE_PREFIX

PARTITION_HEADER

logger

MEDIATYPES_MEDIATYPE_ALL

CONSUMER_STANDARD_PROPERTIES

PRODUCER_STANDARD_PROPERTIES

CONSUMER_RETRY_PROPERTIES

PRODUCER_PARTITIONING_PROPERTIES

PRODUCER_BATCHING_BASIC_PROPERTIES

PRODUCER_BATCHING_ADVANCED_PROPERTIES

evaluationContext

directChannelProvider

defaultBackOffInitialInterval

defaultBackOffMaxInterval

defaultBackOffMultiplier

defaultConcurrency

defaultMaxAttempts

defaultBatchingEnabled

defaultBatchSize

defaultBatchBufferLimit

defaultBatchTimeout

defaultCompress

defaultDurableSubscription

コンストラクターの詳細

MessageBusSupport

メソッドの詳細

applyPrefix

applyPubSub

applyRequests

constructDLQName

setApplicationContext

getApplicationContext

getBeanFactory

setCodec

getIdGenerator

setIntegrationEvaluationContext

setPartitionSelector

setDefaultBackOffInitialInterval

setDefaultBackOffMultiplier

setDefaultBackOffMaxInterval

setDefaultConcurrency

setDefaultMaxAttempts

setDefaultBatchingEnabled

setDefaultBatchSize

setDefaultBatchBufferLimit

setDefaultBatchTimeout

setDefaultCompress

setDefaultDurableSubscription

afterPropertiesSet

onInit

bindDynamicProducer

doBindDynamicProducer

bindDynamicPubSubProducer

doBindDynamicPubSubProducer

unbindConsumers

unbindProducers

unbindConsumer

unbindProducer

isCapable

addBinding

deleteBindings

deleteBinding

stopBindings

serializePayloadIfNecessary

deserializePayloadIfNecessary

deserializePayloadIfNecessary

determinePartition

validateConsumerProperties