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
インターフェース 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()
クラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース DisposableBean から継承されたメソッド
destroy
インターフェース 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

フィールド概要

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

コンストラクター概要

方法の概要

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

インターフェース DisposableBean から継承されたメソッド

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

フィールドの詳細

rSocketMessageHandler

コンストラクターの詳細

AbstractRSocketConnector

方法の詳細

setDataMimeType

getDataMimeType

setMetadataMimeType

getMetadataMimeType

setRSocketStrategies

getRSocketStrategies

setEndpoints

addEndpoint

setApplicationContext

afterPropertiesSet

afterSingletonsInstantiated

setAutoStartup

isAutoStartup

start

doStart

stop

isRunning