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

関連事項:

フィールドのサマリー
フィールド
修飾子と型
フィールド
説明
protected final 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 @Nullable MimeType
getDataMimeType()
protected MimeType
getMetadataMimeType()
RSocketStrategies
getRSocketStrategies()
boolean
isAutoStartup()
boolean
isRunning()
void
setApplicationContext(ApplicationContext applicationContext)
void
setAutoStartup(boolean autoStartup)
void
setDataMimeType(@Nullable 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, isPauseable, 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
  protected @Nullable 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 から継承されたメソッド

フィールドの詳細

rSocketMessageHandler

コンストラクターの詳細

AbstractRSocketConnector

メソッドの詳細

setDataMimeType

getDataMimeType

setMetadataMimeType

getMetadataMimeType

setRSocketStrategies

getRSocketStrategies

setEndpoints

addEndpoint

setApplicationContext

afterPropertiesSet

afterSingletonsInstantiated

setAutoStartup

isAutoStartup

start

doStart

stop

isRunning