- sendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
The Consumer callback to configure a publishing socket.
- setAutoStartup(boolean) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
- setBackendPort(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Specify a fixed port for backend socket of the proxy.
- setBackendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Provide a Consumer to configure a proxy backend socket with arbitrary options, like security.
- setBeanName(String) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
- setBindPort(int) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Configure a port for TCP protocol binding via ZMQ.Socket.bind(String).
- setConnectUrl(String) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Configure a connection to the ZeroMQ proxy with the pair of ports over colon
for proxy frontend and backend sockets.
- setConnectUrl(String) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Configure an URL for ZMQ.Socket.connect(String).
- setConsumeDelay(Duration) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Specify a Duration to delay consumption when no data received.
- setConsumeDelay(Duration) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Specify a Duration to delay consumption when no data received.
- setExposeCaptureSocket(boolean) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Whether to bind and expose a capture socket for the proxy data.
- setFrontendPort(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Specify a fixed port for frontend socket of the proxy.
- setFrontendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Provide a Consumer to configure a proxy frontend socket with arbitrary options, like security.
- setMessageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
- setMessageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide a
MessageConverter (as an alternative to
messageMapper)
for converting a request message into
byte[] for sending into ZeroMq socket.
- setMessageMapper(BytesMessageMapper) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Provide a BytesMessageMapper to convert to/from messages when send or receive happens
on the sockets.
- setMessageMapper(InboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Provide an InboundMessageMapper to convert a consumed data into a message to produce.
- setMessageMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide an OutboundMessageMapper to convert a request message into byte[]
for sending into ZeroMq socket.
- setPhase(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
- setProxyExecutor(Executor) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Configure an executor to perform a ZeroMQ proxy loop.
- setReceiveRaw(boolean) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
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).
- setSendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
The Consumer callback to configure a publishing socket.
- setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Provide a Consumer to configure a socket with arbitrary options, like security.
- setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide a Consumer to configure a socket with arbitrary options, like security.
- setSubscribeSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
The Consumer callback to configure a consuming socket.
- setTopic(String) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Specify a topic the SocketType.PUB socket is going to use for distributing messages into the
subscriptions.
- setTopicExpression(Expression) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Specify a SpEL expression to evaluate a topic a SocketType.PUB
is going to use for distributing messages into the
subscriptions.It is ignored for all other SocketTypes supported.
- setTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Specify topics the SocketType.SUB socket is going to use for subscription.
- setZeroMqProxy(ZeroMqProxy) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Specify a reference to a
ZeroMqProxy instance in the same application
to rely on its ports configuration and make a natural lifecycle dependency without guessing
when the proxy is started.
- socketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Provide a Consumer to configure a socket with arbitrary options, like security.
- socketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Provide a Consumer to configure a socket with arbitrary options, like security.
- start() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
- stop() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
- subscribe(MessageHandler) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
- subscribeSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
The Consumer callback to configure a consuming socket.
- subscribeToTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-