クラス ZeroMqMessageProducerSpec

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

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

    • ZeroMqMessageProducerSpec

      protected ZeroMqMessageProducerSpec(org.zeromq.ZContext context)

    • ZeroMqMessageProducerSpec

      protected ZeroMqMessageProducerSpec(org.zeromq.ZContext context, org.zeromq.SocketType socketType)

  • メソッドの詳細

    • consumeDelay

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

    • messageMapper

      public ZeroMqMessageProducerSpec messageMapper(InboundMessageMapper<byte[]> messageMapper)
      消費されたデータを生成するメッセージに変換する InboundMessageMapper を提供します。
      パラメーター:
      messageMapper - 使用する InboundMessageMapper。
      戻り値:
      スペック

    • messageConverter

      public ZeroMqMessageProducerSpec messageConverter(MessageConverter messageConverter)
      消費されたデータを生成するメッセージに変換するための MessageConverter（messageMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]>) の代替として）を提供します。
      パラメーター:
      messageConverter - 使用する MessageConverter。
      戻り値:
      スペック

    • receiveRaw

      public ZeroMqMessageProducerSpec receiveRaw(boolean receiveRaw)
      生の ZMsg が生成するメッセージのペイロードとして存在するか、ZeroMqHeaders.TOPIC ヘッダー（存在する場合）を含む Message に完全に変換されるかどうか。
      パラメーター:
      receiveRaw - ZMsg から変換するかどうか。デフォルトで変換します。
      戻り値:
      スペック

    • socketConfigurer

      public ZeroMqMessageProducerSpec socketConfigurer(ConsumerSE<org.zeromq.ZMQ.Socket> socketConfigurer)
      ConsumerSE を提供して、セキュリティなどの任意のオプションでソケットを構成します。
      パラメーター:
      socketConfigurer - ソケットオプションのコンフィギュレーター。
      戻り値:
      スペック

    • topics

      public ZeroMqMessageProducerSpec topics(StringSE... topics)
      SocketType.SUB ソケットがサブスクリプションに使用するトピックを指定します。サポートされている他のすべての SocketType では無視されます。
      パラメーター:
      topics - 使用するトピック。
      戻り値:
      スペック

    • unwrapTopic

      public ZeroMqMessageProducerSpec unwrapTopic(boolean unwrapTopic)
      SocketType.SUB ソケットが受信するトピックが追加の空フレームでラップされるかどうかを指定します。サポートされている他のすべての SocketType では無視されます。この属性はデフォルトで true に設定されています。
      パラメーター:
      unwrapTopic - 受信したトピックが追加の空のフレームでラップされている場合は true です。
      戻り値:
      スペック
      導入:
      6.2.6

    • connectUrl

      public ZeroMqMessageProducerSpec connectUrl(StringSE connectUrl)
      ZMQ.Socket.connect(String) の URL を構成します。
      パラメーター:
      connectUrl - ZeroMq ソケットを接続する URL。
      戻り値:
      スペック

    • bindPort

      public ZeroMqMessageProducerSpec bindPort(int port)
      ZMQ.Socket.bind(String) を介した TCP プロトコルバインディング用のポートを構成します。
      パラメーター:
      port - ZeroMq ソケットを TCP 経由でバインドするポート。
      戻り値:
      スペック