public class ZeroMqMessageHandlerSpec extends ReactiveMessageHandlerSpec<ZeroMqMessageHandlerSpec,ZeroMqMessageHandler>
reactiveMessageHandlerPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, StringSE connectUrl) 提供された ZContext と接続文字列に基づいてインスタンスを作成します。 |
protected | ZeroMqMessageHandlerSpec(org.zeromq.ZContext context, StringSE connectUrl, org.zeromq.SocketType socketType) 提供された ZContext、接続文字列、SocketType に基づいてインスタンスを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
ZeroMqMessageHandlerSpec | messageConverter(MessageConverter messageConverter)ZeroMq ソケットに送信するために、リクエストメッセージを byte[] に変換するための MessageConverter(messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>) の代替として)を提供します。 |
ZeroMqMessageHandlerSpec | messageMapper(OutboundMessageMapper<byte[]> messageMapper)ZeroMq ソケットに送信するために、リクエストメッセージを byte[] に変換する OutboundMessageMapper を提供します。 |
ZeroMqMessageHandlerSpec | socketConfigurer(java.util.function.ConsumerSE<org.zeromq.ZMQ.Socket> socketConfigurer)ConsumerSE を提供して、セキュリティなどの任意のオプションでソケットを構成します。 |
ZeroMqMessageHandlerSpec | topic(StringSE topic)SocketType.PUB ソケットがサブスクリプションへのメッセージの配布に使用するトピックを指定します。 |
ZeroMqMessageHandlerSpec | topicExpression(Expression topicExpression)SpEL 式を指定して、 SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。 |
ZeroMqMessageHandlerSpec | topicExpression(StringSE topicExpression)SpEL 式を指定して、 SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。 |
ZeroMqMessageHandlerSpec | topicFunction(java.util.function.FunctionSE<Message<?>,StringSE> topicFunction)FunctionSE を指定して、SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。 |
getComponentsToRegister_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected ZeroMqMessageHandlerSpec(org.zeromq.ZContext context,
StringSE connectUrl)ZContext と接続文字列に基づいてインスタンスを作成します。context - ソケットの作成に使用する ZContext。connectUrl - ソケットを接続する URL。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 のみがサポートされています。public ZeroMqMessageHandlerSpec messageMapper(OutboundMessageMapper<byte[]> messageMapper)
byte[] に変換する OutboundMessageMapper を提供します。messageMapper - 使用する OutboundMessageMapper。public ZeroMqMessageHandlerSpec messageConverter(MessageConverter messageConverter)
byte[] に変換するための MessageConverter(messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>) の代替として)を提供します。messageConverter - 使用する MessageConverter。public ZeroMqMessageHandlerSpec socketConfigurer(java.util.function.ConsumerSE<org.zeromq.ZMQ.Socket> socketConfigurer)
ConsumerSE を提供して、セキュリティなどの任意のオプションでソケットを構成します。socketConfigurer - ソケットオプションのコンフィギュレーター。public ZeroMqMessageHandlerSpec topic(StringSE topic)
SocketType.PUB ソケットがサブスクリプションへのメッセージの配布に使用するトピックを指定します。サポートされている他のすべての SocketType では無視されます。topic - 使用するトピック。public ZeroMqMessageHandlerSpec topicFunction(java.util.function.FunctionSE<Message<?>,StringSE> topicFunction)
FunctionSE を指定して、SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。topicFunction - 公開するトピックを評価するための FunctionSE。public ZeroMqMessageHandlerSpec topicExpression(StringSE topicExpression)
SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。topicExpression - 公開するトピックを評価する式。public ZeroMqMessageHandlerSpec topicExpression(Expression topicExpression)
SocketType.PUB がサブスクリプションへのメッセージの配布に使用するトピックを評価します。サポートされている他のすべての SocketType では無視されます。topicExpression - 公開するトピックを評価する式。