クラスの使用
org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
ZeroMqMessageProducerSpec を使用するパッケージ
org.springframework.integration.zeromq.dsl 内の ZeroMqMessageProducerSpec 使用
修飾子と型メソッド説明ZeroMqMessageProducerSpec.bindPort(int port) ZMQ.Socket.bind(String)を介した TCP プロトコルバインディング用のポートを構成します。ZeroMqMessageProducerSpec.connectUrl(StringSE connectUrl) ZMQ.Socket.connect(String)の URL を構成します。ZeroMqMessageProducerSpec.consumeDelay(DurationSE consumeDelay) データが受信されないときに消費を遅らせるには、DurationSE を指定します。static ZeroMqMessageProducerSpecZeroMq.inboundChannelAdapter(org.zeromq.ZContext context) 提供されたZContextのZeroMqMessageProducerSpecのインスタンスを作成します。static ZeroMqMessageProducerSpecZeroMq.inboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType) ZeroMqMessageProducerSpec.messageConverter(MessageConverter messageConverter) 消費されたデータを生成するメッセージに変換するためのMessageConverter（messageMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]>)の代替として）を提供します。ZeroMqMessageProducerSpec.messageMapper(InboundMessageMapper<byte[]> messageMapper) 消費されたデータを生成するメッセージに変換するInboundMessageMapperを提供します。ZeroMqMessageProducerSpec.receiveRaw(boolean receiveRaw) ZeroMqMessageProducerSpec.socketConfigurer(ConsumerSE<org.zeromq.ZMQ.Socket> socketConfigurer) ConsumerSE を提供して、セキュリティなどの任意のオプションでソケットを構成します。SocketType.SUBソケットがサブスクリプションに使用するトピックを指定します。ZeroMqMessageProducerSpec.unwrapTopic(boolean unwrapTopic) SocketType.SUBソケットが受信するトピックが追加の空フレームでラップされるかどうかを指定します。