コンストラクターの詳細

• SimpleBrokerMessageHandler

  public SimpleBrokerMessageHandler(SubscribableChannel clientInboundChannel,
                                    MessageChannel clientOutboundChannel,
                                    SubscribableChannel brokerChannel,
                                    CollectionSE<StringSE> destinationPrefixes)

  指定されたメッセージチャネルと宛先プレフィックスを使用して SimpleBrokerMessageHandler インスタンスを作成します。

  パラメーター:

  clientInboundChannel - クライアントからメッセージを受信するためのチャネル (たとえば WebSocket クライアント)

  clientOutboundChannel - クライアントにメッセージを送信するためのチャネル (たとえば WebSocket クライアント)

  brokerChannel - アプリケーションがブローカーにメッセージを送信するためのチャネル

  destinationPrefixes - メッセージを除外するために使用するプレフィックス

メソッドの詳細

• setSubscriptionRegistry

  public void setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry)

  サブスクリプションの保存に使用するカスタム SubscriptionRegistry を構成します。

  カスタム PathMatcher が setPathMatcher(org.springframework.util.PathMatcher) を介して構成されている場合、カスタムレジストリが DefaultSubscriptionRegistry のインスタンスではない場合、提供 PathMatcher が使用されていない、カスタムレジストリに直接設定されなければならないことに留意されたいです。

• getSubscriptionRegistry

  public SubscriptionRegistry getSubscriptionRegistry()

• setPathMatcher

  public void setPathMatcher(@Nullable
                             PathMatcher pathMatcher)

  構成すると、指定された PathMatcher が基になる SubscriptionRegistry に渡され、宛先をサブスクリプションに一致させるために使用されます。

  デフォルトは標準 AntPathMatcher です。

  導入:

  4.1

  関連事項:

  setSubscriptionRegistry(org.springframework.messaging.simp.broker.SubscriptionRegistry), DefaultSubscriptionRegistry.setPathMatcher(org.springframework.util.PathMatcher), AntPathMatcher

• setCacheLimit

  public void setCacheLimit(@Nullable
                            IntegerSE cacheLimit)

  設定されると、指定されたキャッシュ制限が基礎となる SubscriptionRegistry に渡され、そこでデフォルトが上書きされます。

  標準 DefaultSubscriptionRegistry では、デフォルトのキャッシュ制限は 1024 です。

  導入:

  4.3.2

  関連事項:

  setSubscriptionRegistry(org.springframework.messaging.simp.broker.SubscriptionRegistry), DefaultSubscriptionRegistry.setCacheLimit(int), DefaultSubscriptionRegistry.DEFAULT_CACHE_LIMIT

• setSelectorHeaderName

  public void setSelectorHeaderName(@Nullable
                                    StringSE selectorHeaderName)

  サブスクリプションに一致するメッセージをフィルター処理するために、サブスクリプションメッセージに含めることができるヘッダーの名前を構成します。ヘッダー値は、サブスクリプションに一致するメッセージのヘッダーに適用される Spring EL ブール式であることが期待されています。

  例:

   headers.foo == 'bar'
   

  デフォルトでは、これは「セレクタ」に設定されています。別の名前に設定するか、null に設定して、セレクタヘッダーのサポートをオフにすることができます。

  パラメーター:

  selectorHeaderName - セレクターヘッダーに使用する名前

  導入:

  4.3.17

  関連事項:

  setSubscriptionRegistry(org.springframework.messaging.simp.broker.SubscriptionRegistry), DefaultSubscriptionRegistry.setSelectorHeaderName(String)

• setTaskScheduler

  public void setTaskScheduler(@Nullable
                               TaskScheduler taskScheduler)

  TaskScheduler を構成して、ハートビートサポートの提供に使用します。このプロパティを設定すると、heartbeatValue も "10000, 10000" に設定されます。

  デフォルトでは、これは設定されていません。

  導入:

  4.2

• getTaskScheduler

  @Nullable
  public TaskScheduler getTaskScheduler()

  設定された TaskScheduler を返します。

  導入:

  4.2

• setHeartbeatValue

  public void setHeartbeatValue(@Nullable
                                long[] heartbeat)

  ハートビート設定の値を構成します。最初の数値は、サーバーがハートビートを書き込むまたは送信する頻度を表します。2 番目は、クライアントが書き込む頻度です。0 はハートビートがないことを意味します。

  デフォルトでは、taskScheduler の場合を除き、これは "0, 0" に設定されます。taskScheduler の場合、デフォルトは "10000,10000" （ミリ秒単位）になります。

  導入:

  4.2

• getHeartbeatValue

  @Nullable
  public long[] getHeartbeatValue()

  ハートビート設定の構成値。

  導入:

  4.2

• setHeaderInitializer

  public void setHeaderInitializer(@Nullable
                                   MessageHeaderInitializer headerInitializer)

  MessageHeaderInitializer を構成して、クライアント送信チャネルに送信されるすべてのメッセージのヘッダーに適用します。

  デフォルトでは、このプロパティは設定されていません。

  導入:

  4.1

• getHeaderInitializer

  @Nullable
  public MessageHeaderInitializer getHeaderInitializer()

  設定済みのヘッダー初期化子を返します。

  導入:

  4.1

• startInternal

  public void startInternal()

  オーバーライド:

  クラス AbstractBrokerMessageHandler の startInternal 

• stopInternal

  public void stopInternal()

  オーバーライド:

  クラス AbstractBrokerMessageHandler の stopInternal 

• handleMessageInternal

  protected void handleMessageInternal(Message<?> message)

  次で指定:

  クラス AbstractBrokerMessageHandler の handleMessageInternal 

• sendMessageToSubscribers

  protected void sendMessageToSubscribers(@Nullable
                                          StringSE destination,
                                          Message<?> message)

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toStringSE