public class SimpleBrokerRegistration extends AbstractBrokerRegistration
SimpleBrokerMessageHandler
を構成するための登録クラス。コンストラクターと説明 |
---|
SimpleBrokerRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes) 新しい SimpleBrokerRegistration を作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
protected SimpleBrokerMessageHandler | getMessageHandler(SubscribableChannel brokerChannel) |
SimpleBrokerRegistration | setHeartbeatValue(long[] heartbeat) ハートビート設定の値を構成します。 |
void | setSelectorHeaderName(StringSE selectorHeaderName) サブスクリプションに一致するメッセージをフィルター処理するために、サブスクリプションメッセージに含めることができるヘッダーの名前を構成します。 |
SimpleBrokerRegistration | setTaskScheduler(TaskScheduler taskScheduler) TaskScheduler を構成して、ハートビートサポートの提供に使用します。 |
getClientInboundChannel, getClientOutboundChannel, getDestinationPrefixes
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public SimpleBrokerRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes)
SimpleBrokerRegistration
を作成します。clientInboundChannel
- 受信チャネル clientOutboundChannel
- 送信チャネル destinationPrefixes
- 宛先プレフィックス public SimpleBrokerRegistration setTaskScheduler(TaskScheduler taskScheduler)
TaskScheduler
を構成して、ハートビートサポートの提供に使用します。このプロパティを設定すると、heartbeatValue
も "10000, 10000" に設定されます。デフォルトでは、これは設定されていません。
public SimpleBrokerRegistration setHeartbeatValue(long[] heartbeat)
デフォルトでは、taskScheduler
の場合を除き、これは "0, 0" に設定されます。taskScheduler
の場合、デフォルトは "10000,10000" (ミリ秒単位)になります。
public void setSelectorHeaderName(@Nullable StringSE selectorHeaderName)
例:
headers.foo == 'bar'
デフォルトでは、これは「セレクタ」に設定されています。別の名前に設定するか、null
に設定して、セレクタヘッダーのサポートをオフにすることができます。
selectorHeaderName
- セレクターヘッダーに使用する名前 protected SimpleBrokerMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
AbstractBrokerRegistration
の getMessageHandler