Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
Package
Description
Provides classes for supporting ZeroMQ component via Java DSL.
-
Uses of ZeroMqChannelSpec in org.springframework.integration.zeromq.dsl
Modifier and TypeMethodDescriptionZeroMqChannelSpec.connectUrl
(String connectUrl) Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.ZeroMqChannelSpec.consumeDelay
(Duration consumeDelay) Specify aDuration
to delay consumption when no data received.ZeroMqChannelSpec.messageMapper
(BytesMessageMapper messageMapper) Provide aBytesMessageMapper
to convert to/from messages when send or receive happens on the sockets.static ZeroMqChannelSpec
ZeroMq.pubSubZeroMqChannel
(org.zeromq.ZContext context) Create an instance ofZeroMqChannelSpec
in pub/sub mode based on the providedZContext
.ZeroMqChannelSpec.sendSocketConfigurer
(Consumer<org.zeromq.ZMQ.Socket> sendSocketConfigurer) TheConsumer
callback to configure a publishing socket.ZeroMqChannelSpec.subscribeSocketConfigurer
(Consumer<org.zeromq.ZMQ.Socket> subscribeSocketConfigurer) TheConsumer
callback to configure a consuming socket.static ZeroMqChannelSpec
ZeroMq.zeroMqChannel
(org.zeromq.ZContext context) Create an instance ofZeroMqChannelSpec
based on the providedZContext
.ZeroMqChannelSpec.zeroMqProxy
(ZeroMqProxy zeroMqProxy) Specify a reference to aZeroMqProxy
instance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started.