クラス ZeroMqMessageHandlerSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<ZeroMqMessageHandlerSpec, ReactiveMessageHandlerAdapter>
org.springframework.integration.dsl.MessageHandlerSpec<ZeroMqMessageHandlerSpec, ReactiveMessageHandlerAdapter>
org.springframework.integration.dsl.ReactiveMessageHandlerSpec<ZeroMqMessageHandlerSpec, ZeroMqMessageHandler>
org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
実装されているすべてのインターフェース:
DisposableBean、FactoryBean<ReactiveMessageHandlerAdapter>、InitializingBean、Lifecycle、Phased、SmartLifecycle、ComponentsRegistration
public class ZeroMqMessageHandlerSpec extends ReactiveMessageHandlerSpec<ZeroMqMessageHandlerSpec, ZeroMqMessageHandler>
ZeroMqMessageHandler の ReactiveMessageHandlerSpec 拡張。
導入:
5.4
作成者:
Artem Bilan, Alessio Matricardi

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

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, StringSE connectUrl)
      提供された ZContext と接続文字列に基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      connectUrl - ソケットを接続する URL。

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context)
      提供された ZContext に基づいてインスタンスを作成します。作成されたソケットはランダムなポートにバインドされます。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      導入:
      6.4

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, int port)
      提供された ZContext とバインディングポートに基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      port - ZeroMq ソケットを TCP 経由でバインドするポート。
      導入:
      6.4

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, SupplierSE<StringSE> connectUrl)
      提供されている ZContext および接続文字列サプライヤーに基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      connectUrl - ソケットを接続する URL のサプライヤー。
      導入:
      5.5.9

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, StringSE connectUrl, org.zeromq.SocketType socketType)
      提供された ZContext、接続文字列、SocketType に基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      connectUrl - ソケットを接続する URL。
      socketType - 使用する SocketType。SocketType.PAIR、SocketType.PUB、SocketType.PUSH のみがサポートされています。

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, org.zeromq.SocketType socketType)
      提供された ZContext と SocketType に基づいてインスタンスを作成します。作成されたソケットはランダムなポートにバインドされます。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      socketType - 使用する SocketType。SocketType.PAIR、SocketType.PUB、SocketType.PUSH のみがサポートされています。
      導入:
      6.4

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, int port, org.zeromq.SocketType socketType)
      提供された ZContext、バインディングポート、および SocketType に基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      port - ZeroMq ソケットを TCP 経由でバインドするポート。
      socketType - 使用する SocketType。SocketType.PAIR、SocketType.PUB、SocketType.PUSH のみがサポートされています。
      導入:
      6.4

    • ZeroMqMessageHandlerSpec

      protected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, SupplierSE<StringSE> connectUrl, org.zeromq.SocketType socketType)
      提供されている ZContext、接続文字列サプライヤー、SocketType に基づいてインスタンスを作成します。
      パラメーター:
      context - ソケットの作成に使用する ZContext。
      connectUrl - ソケットを接続する URL のサプライヤー。
      socketType - 使用する SocketType。SocketType.PAIR、SocketType.PUB、SocketType.PUSH のみがサポートされています。

  • メソッドの詳細

    • messageMapper

      public ZeroMqMessageHandlerSpec messageMapper(OutboundMessageMapper<byte[]> messageMapper)
      ZeroMq ソケットに送信するために、リクエストメッセージを byte[] に変換する OutboundMessageMapper を提供します。
      パラメーター:
      messageMapper - 使用する OutboundMessageMapper。
      戻り値:
      スペック

    • messageConverter

      public ZeroMqMessageHandlerSpec messageConverter(MessageConverter messageConverter)
      ZeroMq ソケットに送信するために、リクエストメッセージを byte[] に変換するための MessageConverter（messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>) の代替として）を提供します。
      パラメーター:
      messageConverter - 使用する MessageConverter。
      戻り値:
      スペック

    • socketConfigurer

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

    • topic

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

    • wrapTopic

      public ZeroMqMessageHandlerSpec wrapTopic(boolean wrapTopic)
      SocketType.PUB ソケットがサブスクリプションにメッセージを配信するために使用するトピックが、追加の空のフレームでラップされる必要があるかどうかを指定します。サポートされている他のすべての SocketType では無視されます。この属性は、デフォルトで true に設定されています。
      パラメーター:
      wrapTopic - トピックを追加の空フレームで囲む必要がある場合は true です。
      戻り値:
      スペック
      導入:
      6.2.6

    • topicFunction

      public ZeroMqMessageHandlerSpec topicFunction(FunctionSE<Message<?>, StringSE> topicFunction)
      FunctionSE を指定して、SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。
      パラメーター:
      topicFunction - 公開するトピックを評価するための FunctionSE。
      戻り値:
      スペック

    • topicExpression

      public ZeroMqMessageHandlerSpec topicExpression(StringSE topicExpression)
      SpEL 式を指定して、SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。
      パラメーター:
      topicExpression - 公開するトピックを評価する式。
      戻り値:
      スペック

    • topicExpression

      public ZeroMqMessageHandlerSpec topicExpression(Expression topicExpression)
      SpEL 式を指定して、SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。
      パラメーター:
      topicExpression - 公開するトピックを評価する式。
      戻り値:
      スペック