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)` Set the default batch buffer limit - used to send a batch early if its size exceeds this.
`void`	`setDefaultBatchingEnabled(boolean defaultBatchingEnabled)` Set whether this bus batches message sends by default.
`void`	`setDefaultBatchSize(int defaultBatchSize)` Set the default batch size; only applies when batching is enabled and the bus supports batching.
`void`	`setDefaultBatchTimeout(long defaultBatchTimeout)` Set the default batch timeout - used to send a batch if no messages arrive during this time.
`void`	`setDefaultCompress(boolean defaultCompress)` Set whether compression will be used by producers, by default.
`void`	`setDefaultConcurrency(int defaultConcurrency)` このバスのデフォルトの同時実行性を設定します。コンシューマーの「同時実行性」プロパティで上書きできます。
`void`	`setDefaultDurableSubscription(boolean defaultDurableSubscription)` Set whether subscriptions to taps/topics are durable.
`void`	`setDefaultMaxAttempts(int defaultMaxAttempts)` このバスのデフォルトの最大配信試行回数。
`void`	`setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)`
`void`	`setPartitionSelector(PartitionSelectorStrategy partitionSelector)` Set the partition strategy to be used by this bus if no partitionExpression is provided for a module.
`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)` Validate the provided deployment properties for the consumer against those supported by this bus implementation.
`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.

クラス 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 - 名前。
    戻り値:
    the request entity 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)
```
    Set the partition strategy to be used by this bus if no partitionExpression is provided for a module.
    パラメーター:
    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)
```
    The default maximum delivery attempts for this bus. Can be overridden by consumer property 'maxAttempts' if supported. Values less than 2 disable retry and one delivery attempt is made.
    パラメーター:
    defaultMaxAttempts - デフォルトの最大試行回数。
  - setDefaultBatchingEnabled
```
public void setDefaultBatchingEnabled(boolean defaultBatchingEnabled)
```
    Set whether this bus batches message sends by default. Only applies to bus implementations that support batching.
    パラメーター:
    defaultBatchingEnabled - defaultBatchingEnabled を設定します。
  - setDefaultBatchSize
```
public void setDefaultBatchSize(int defaultBatchSize)
```
    Set the default batch size; only applies when batching is enabled and the bus supports batching.
    パラメーター:
    defaultBatchSize - defaultBatchSize を設定します。
  - setDefaultBatchBufferLimit
```
public void setDefaultBatchBufferLimit(int defaultBatchBufferLimit)
```
    Set the default batch buffer limit - used to send a batch early if its size exceeds this. Only applies if batching is enabled and the bus supports this property.
    パラメーター:
    defaultBatchBufferLimit - defaultBatchBufferLimit を設定します。
  - setDefaultBatchTimeout
```
public void setDefaultBatchTimeout(long defaultBatchTimeout)
```
    Set the default batch timeout - used to send a batch if no messages arrive during this time. Only applies if batching is enabled and the bus supports this property.
    パラメーター:
    defaultBatchTimeout - defaultBatchTimeout を設定します。
  - setDefaultCompress
```
public void setDefaultCompress(boolean defaultCompress)
```
    Set whether compression will be used by producers, by default.
    パラメーター:
    defaultCompress - 'true' to use compression.
  - setDefaultDurableSubscription
```
public void setDefaultDurableSubscription(boolean defaultDurableSubscription)
```
    Set whether subscriptions to taps/topics are durable.
    パラメーター:
    defaultDurableSubscription - true for durable (default 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)
```
    Create a producer for the named channel and bind it to the bus. Synchronized to avoid creating multiple instances.
    パラメーター:
    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)
```
    Create a producer for the named channel and bind it to the bus. Synchronized to avoid creating multiple instances.
    パラメーター:
    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