java.lang.ObjectSE

org.springframework.integration.rsocket.AbstractRSocketConnector

実装されているすべてのインターフェース:: Aware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle

既知の直属サブクラス: ClientRSocketConnector, ServerRSocketConnector

public abstract class AbstractRSocketConnector
extends ObjectSE
implements ApplicationContextAware, InitializingBean, DisposableBean, SmartInitializingSingleton, SmartLifecycle

一般的な RSocket クライアントおよびサーバー機能用のベースコネクターコンテナー。

すべての Bean がアプリケーションコンテキストで準備ができている場合、内部 IntegrationRSocketMessageHandler を介してマッピング登録用の IntegrationRSocketEndpoint インスタンスを受け入れるか、それ以外の場合は自動検出を実行します。

導入:: 5.2
作成者:: Artem Bilan
関連事項:: IntegrationRSocketMessageHandler

フィールドのサマリー
フィールド
修飾子と型フィールド説明
protected org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE

コンストラクターの概要

コンストラクター
修飾子	コンストラクター	説明
`protected`	`AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)`

メソッドのサマリー

修飾子と型	メソッド	説明
`void`	`addEndpoint(IntegrationRSocketEndpoint endpoint)`	RSocket リクエストをマッピングおよび処理するための `IntegrationRSocketEndpoint` を追加します。
`void`	`afterPropertiesSet()`
`void`	`afterSingletonsInstantiated()`
`protected abstract void`	`doStart()`
`protected MimeType`	`getDataMimeType()`
`protected MimeType`	`getMetadataMimeType()`
`RSocketStrategies`	`getRSocketStrategies()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`void`	`setApplicationContext(ApplicationContext applicationContext)`
`void`	`setAutoStartup(boolean autoStartup)`
`void`	`setDataMimeType(MimeType dataMimeType)`	データ交換用に `MimeType` を構成します。
`void`	`setEndpoints(IntegrationRSocketEndpoint... endpoints)`	リクエストのマッピングと処理のために `IntegrationRSocketEndpoint` インスタンスを構成します。
`void`	`setMetadataMimeType(MimeType metadataMimeType)`	メタデータ交換用に `MimeType` を構成します。
`void`	`setRSocketStrategies(RSocketStrategies rsocketStrategies)`	データのエンコード / デコード用に `RSocketStrategies` を構成します。
`void`	`start()`
`void`	`stop()`

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

clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

インターフェース org.springframework.beans.factory.DisposableBean から継承されたメソッド

destroy

インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド

getPhase, stop

フィールドの詳細
- rSocketMessageHandler
  protected final org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler
コンストラクターの詳細
- AbstractRSocketConnector
  protected AbstractRSocketConnector(org.springframework.integration.rsocket.IntegrationRSocketMessageHandler rSocketMessageHandler)
メソッドの詳細
- setDataMimeType
  public void setDataMimeType(@Nullable MimeType dataMimeType)
  データ交換用に MimeType を構成します。
  パラメーター:
  dataMimeType - 使用する MimeType。
- getDataMimeType
  @Nullable protected MimeType getDataMimeType()
- setMetadataMimeType
  public void setMetadataMimeType(MimeType metadataMimeType)
  メタデータ交換用に MimeType を構成します。デフォルトは "message/x.rsocket.composite-metadata.v0" です。
  パラメーター:
  metadataMimeType - 使用する MimeType。
- getMetadataMimeType
  protected MimeType getMetadataMimeType()
- setRSocketStrategies
  public void setRSocketStrategies(RSocketStrategies rsocketStrategies)
  データのエンコード / デコード用に RSocketStrategies を構成します。
  パラメーター:
  rsocketStrategies - 使用する RSocketStrategies。
- getRSocketStrategies
  public RSocketStrategies getRSocketStrategies()
- setEndpoints
  public void setEndpoints(IntegrationRSocketEndpoint... endpoints)
  リクエストのマッピングと処理のために IntegrationRSocketEndpoint インスタンスを構成します。
  パラメーター:
  endpoints - 受信リクエストを処理するための IntegrationRSocketEndpoint インスタンス。
  関連事項:
  addEndpoint(IntegrationRSocketEndpoint)
- addEndpoint
  public void addEndpoint(IntegrationRSocketEndpoint endpoint)
  RSocket リクエストをマッピングおよび処理するための IntegrationRSocketEndpoint を追加します。
  パラメーター:
  endpoint - マップする IntegrationRSocketEndpoint。
- setApplicationContext
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
  次で指定:
  インターフェース ApplicationContextAware の setApplicationContext
  例外:
  BeansException
- afterPropertiesSet
  public void afterPropertiesSet()
  次で指定:
  インターフェース InitializingBean の afterPropertiesSet
- afterSingletonsInstantiated
  public void afterSingletonsInstantiated()
  次で指定:
  インターフェース SmartInitializingSingleton の afterSingletonsInstantiated
- setAutoStartup
  public void setAutoStartup(boolean autoStartup)
- isAutoStartup
  public boolean isAutoStartup()
  次で指定:
  インターフェース SmartLifecycle の isAutoStartup
- start
  public void start()
  次で指定:
  インターフェース Lifecycle の start
- doStart
  protected abstract void doStart()
- stop
  public void stop()
  次で指定:
  インターフェース Lifecycle の stop
- isRunning
  public boolean isRunning()
  次で指定:
  インターフェース Lifecycle の isRunning

クラス AbstractRSocketConnector

フィールドのサマリー

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

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

インターフェース org.springframework.beans.factory.DisposableBean から継承されたメソッド

インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド

フィールドの詳細

コンストラクターの詳細

メソッドの詳細