コンストラクターの詳細

• UserDestinationMessageHandler

  public UserDestinationMessageHandler(SubscribableChannel clientInboundChannel,
                                       SubscribableChannel brokerChannel,
                                       UserDestinationResolver resolver)

  指定されたクライアントとブローカーチャネルをサブスクライブしてインスタンスを作成し、それぞれからのメッセージを処理して、解決されたメッセージをブローカーチャネルに送信します。

  パラメーター:

  clientInboundChannel - クライアントから受信したメッセージ。

  brokerChannel - ブローカーに送信されたメッセージ。

  resolver - 「ユーザー」宛先のリゾルバー。

メソッドの詳細

• getUserDestinationResolver

  public UserDestinationResolver getUserDestinationResolver()

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

• setBroadcastDestination

  public void setBroadcastDestination(@Nullable
                                      StringSE destination)

  ユーザーが接続されていないため未解決のままになるメッセージをブロードキャストする宛先を設定します。マルチアプリケーションサーバーのシナリオでは、これにより他のアプリケーションサーバーが試す機会が与えられます。

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

  パラメーター:

  destination - ターゲット宛先。

• getBroadcastDestination

  @Nullable
  public StringSE getBroadcastDestination()

  未解決のメッセージの構成済み宛先を返します。

• getBrokerMessagingTemplate

  public MessageSendingOperations<StringSE> getBrokerMessagingTemplate()

  解決されたメッセージをブローカーチャネルに送信するために使用されるメッセージングテンプレートを返します。

• setHeaderInitializer

  public void setHeaderInitializer(@Nullable
                                   MessageHeaderInitializer headerInitializer)

  カスタム MessageHeaderInitializer を構成して、解決されたターゲットメッセージのヘッダーを初期化します。

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

• getHeaderInitializer

  @Nullable
  public MessageHeaderInitializer getHeaderInitializer()

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

• getPhase

  public int getPhase()

  インターフェースからコピーされた説明: Phased
  このオブジェクトのフェーズ値を返します。

  次で指定:

  インターフェース Phased 内の getPhase 

• isAutoStartup

  public boolean isAutoStartup()

  インターフェースからコピーされた説明: SmartLifecycle
  true が含まれる ApplicationContext がリフレッシュされるときに、この Lifecycle コンポーネントがコンテナーによって自動的に開始される場合、true を返します。

  false の値は、プレーン Lifecycle 実装に類似した、明示的な Lifecycle.start() 呼び出しを介してコンポーネントが開始されることを意図していることを示します。

  次で指定:

  インターフェース SmartLifecycle 内の isAutoStartup 

  関連事項:

  Lifecycle.start(), Phased.getPhase(), LifecycleProcessor.onRefresh(), ConfigurableApplicationContext.refresh()

• start

  public final void start()

  インターフェースからコピーされた説明: Lifecycle
  このコンポーネントを起動します。

  コンポーネントがすでに実行されている場合は、例外をスローしないでください。

  コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。

  次で指定:

  インターフェース Lifecycle 内の start 

  関連事項:

  SmartLifecycle.isAutoStartup()

• stop

  public final void stop()

  インターフェースからコピーされた説明: Lifecycle
  このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

  この停止通知が破棄の前に来るとは限らないことに注意してください。通常のシャットダウンでは、Lifecycle Bean は一般的な破棄コールバックが伝達される前に、まず停止通知を受け取ります。ただし、コンテキストの有効期間中のホットリフレッシュ時、またはリフレッシュ試行が中止されたときは、destroy メソッドのみが呼び出されます。

  コンポーネントがまだ開始されていない場合は、例外をスローしないでください。

  コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

  次で指定:

  インターフェース Lifecycle 内の stop 

  関連事項:

  SmartLifecycle.stop(Runnable), DisposableBean.destroy()

• stop

  public final void stop(RunnableSE callback)

  インターフェースからコピーされた説明: SmartLifecycle
  Lifecycle コンポーネントが現在実行中の場合、停止する必要があることを示します。

  提供されたコールバックは、LifecycleProcessor によって使用され、共通のシャットダウン順序値を持つすべてのコンポーネントの順序付けられた、潜在的に同時のシャットダウンをサポートします。コールバック は、SmartLifecycle コンポーネントが実際に停止した後に実行する必要があります。

  LifecycleProcessor は、stop メソッドのこのバリアントのみを呼び出します。つまり、SmartLifecycle 実装では、このメソッドの実装内に明示的に委譲されない限り、Lifecycle.stop() は呼び出されません。

  次で指定:

  インターフェース SmartLifecycle 内の stop 

  関連事項:

  Lifecycle.stop(), Phased.getPhase()

• isRunning

  public final boolean isRunning()

  インターフェースからコピーされた説明: Lifecycle
  このコンポーネントが現在実行されているかどうかを確認します。

  コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

  次で指定:

  インターフェース Lifecycle 内の isRunning 

  戻り値:

  コンポーネントが現在実行中かどうか

• handleMessage

  public void handleMessage(Message<?> message)
                     throws MessagingException

  インターフェースからコピーされた説明: MessageHandler
  指定されたメッセージを処理します。

  次で指定:

  インターフェース MessageHandler 内の handleMessage 

  パラメーター:

  message - 処理するメッセージ

  例外:

  MessagingException

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toStringSE