クラス ZeroMqChannelSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<ZeroMqChannelSpec,ZeroMqChannel>
org.springframework.integration.dsl.MessageChannelSpec<ZeroMqChannelSpec,ZeroMqChannel>
org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<ZeroMqChannel>、InitializingBean、Lifecycle、Phased、SmartLifecycle、ComponentsRegistration
public class ZeroMqChannelSpec extends MessageChannelSpec<ZeroMqChannelSpec,ZeroMqChannel>
ZeroMqChannel の MessageChannelSpec。
導入:
5.4
作成者:
Artem Bilan

  • コンストラクターの詳細

    • ZeroMqChannelSpec

      protected ZeroMqChannelSpec(org.zeromq.ZContext context, boolean pubSub)

  • メソッドの詳細

    • connectUrl

      public ZeroMqChannelSpec connectUrl(StringSE connectUrl)
      プロキシのフロントエンドおよびバックエンドソケットのコロンを介してポートのペアで ZeroMQ プロキシへの接続を構成します。zeroMqProxy(ZeroMqProxy) と相互に排他的です。
      パラメーター:
      connectUrl - PROTOCOL://HOST:FRONTEND_PORT:BACKEND_PORT 形式の接続文字列。tcp://localhost:6001:6002
      戻り値:
      スペック

    • zeroMqProxy

      public ZeroMqChannelSpec zeroMqProxy(ZeroMqProxy zeroMqProxy)
      同じアプリケーションで ZeroMqProxy インスタンスへの参照を指定して、そのポート構成に依存し、プロキシがいつ起動されるかを推測することなく、自然なライフサイクル依存関係を作成します。connectUrl(String) と相互に排他的です。
      パラメーター:
      zeroMqProxy - 使用する ZeroMqProxy インスタンス
      戻り値:
      スペック

    • consumeDelay

      public ZeroMqChannelSpec consumeDelay(DurationSE consumeDelay)
      データが受信されないときに消費を遅らせるには、DurationSE を指定します。
      パラメーター:
      consumeDelay - 空のときに消費を遅らせる DurationSE。デフォルトは ZeroMqChannel.DEFAULT_CONSUME_DELAY です。
      戻り値:
      スペック

    • messageMapper

      public ZeroMqChannelSpec messageMapper(BytesMessageMapper messageMapper)
      ソケットで送信または受信が発生したときにメッセージとの間で変換する BytesMessageMapper を提供します。
      パラメーター:
      messageMapper - 使用する BytesMessageMapper。
      戻り値:
      スペック

    • sendSocketConfigurer

      public ZeroMqChannelSpec sendSocketConfigurer(ConsumerSE<org.zeromq.ZMQ.Socket> sendSocketConfigurer)
      パブリッシングソケットを構成するための ConsumerSE コールバック。
      パラメーター:
      sendSocketConfigurer - 使用する ConsumerSE。
      戻り値:
      スペック

    • subscribeSocketConfigurer

      public ZeroMqChannelSpec subscribeSocketConfigurer(ConsumerSE<org.zeromq.ZMQ.Socket> subscribeSocketConfigurer)
      消費ソケットを構成するための ConsumerSE コールバック。
      パラメーター:
      subscribeSocketConfigurer - 使用する ConsumerSE。
      戻り値:
      スペック