Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec

Packages that use ZeroMqMessageProducerSpec

Package	Description
org.springframework.integration.zeromq.dsl	Provides classes for supporting ZeroMQ component via Java DSL.

Uses of ZeroMqMessageProducerSpec in org.springframework.integration.zeromq.dsl

Methods in org.springframework.integration.zeromq.dsl that return ZeroMqMessageProducerSpec

Modifier and Type	Method	Description
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.bindPort(int port)	Configure a port for TCP protocol binding via ZMQ.Socket.bind(String).
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.connectUrl(String connectUrl)	Configure an URL for ZMQ.Socket.connect(String).
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.consumeDelay(Duration consumeDelay)	Specify a Duration to delay consumption when no data received.
static ZeroMqMessageProducerSpec	ZeroMq.inboundChannelAdapter(org.zeromq.ZContext context)	Create an instance of ZeroMqMessageProducerSpec for the provided ZContext.
static ZeroMqMessageProducerSpec	ZeroMq.inboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)	Create an instance of ZeroMqMessageProducerSpec for the provided ZContext and SocketType.
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.messageConverter(MessageConverter messageConverter)	Provide a MessageConverter (as an alternative to messageMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]>)) for converting a consumed data into a message to produce.
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.messageMapper(InboundMessageMapper<byte[]> messageMapper)	Provide an InboundMessageMapper to convert a consumed data into a message to produce.
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.receiveRaw(boolean receiveRaw)	Whether raw ZMsg is present as a payload of message to produce or it is fully converted to a Message including ZeroMqHeaders.TOPIC header (if any).
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.socketConfigurer(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer)	Provide a Consumer to configure a socket with arbitrary options, like security.
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.topics(String... topics)	Specify topics the SocketType.SUB socket is going to use for subscription.
ZeroMqMessageProducerSpec	ZeroMqMessageProducerSpec.unwrapTopic(boolean unwrapTopic)	Specify if the topic that SocketType.SUB socket is going to receive is wrapped with an additional empty frame.