public class ZeroMqMessageProducerSpec extends MessageProducerSpec<ZeroMqMessageProducerSpec,ZeroMqMessageProducer>
PARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | ZeroMqMessageProducerSpec(org.zeromq.ZContext context) |
protected | ZeroMqMessageProducerSpec(org.zeromq.ZContext context, org.zeromq.SocketType socketType) |
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, shouldTrack_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected ZeroMqMessageProducerSpec(org.zeromq.ZContext context)
protected ZeroMqMessageProducerSpec(org.zeromq.ZContext context,
org.zeromq.SocketType socketType)public ZeroMqMessageProducerSpec consumeDelay(java.time.Duration consumeDelay)
Duration を指定します。consumeDelay - 空のときに消費を遅らせる Duration。public ZeroMqMessageProducerSpec messageMapper(InboundMessageMapper<byte[]> messageMapper)
InboundMessageMapper を提供します。messageMapper - 使用する InboundMessageMapper。public ZeroMqMessageProducerSpec messageConverter(MessageConverter messageConverter)
MessageConverter(messageMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]>) の代替として)を提供します。messageConverter - 使用する MessageConverter。public ZeroMqMessageProducerSpec receiveRaw(boolean receiveRaw)
receiveRaw - ZMsg から変換するかどうか。デフォルトで変換します。public ZeroMqMessageProducerSpec socketConfigurer(java.util.function.ConsumerSE<org.zeromq.ZMQ.Socket> socketConfigurer)
ConsumerSE を提供して、セキュリティなどの任意のオプションでソケットを構成します。socketConfigurer - ソケットオプションのコンフィギュレーター。public ZeroMqMessageProducerSpec topics(StringSE... topics)
SocketType.SUB ソケットがサブスクリプションに使用するトピックを指定します。サポートされている他のすべての SocketType では無視されます。topics - 使用するトピック。public ZeroMqMessageProducerSpec connectUrl(StringSE connectUrl)
ZMQ.Socket.connect(String) の URL を構成します。connectUrl - ZeroMq ソケットを接続する URL。public ZeroMqMessageProducerSpec bindPort(int port)
ZMQ.Socket.bind(String) を介した TCP プロトコルバインディング用のポートを構成します。port - ZeroMq ソケットを TCP 経由でバインドするポート。