Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
Packages that use ZeroMqChannelSpec
Package
Description
Provides classes for supporting ZeroMQ component via Java DSL.
-
Uses of ZeroMqChannelSpec in org.springframework.integration.zeromq.dsl
Methods in org.springframework.integration.zeromq.dsl that return ZeroMqChannelSpecModifier 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 aDurationto delay consumption when no data received.ZeroMqChannelSpec.messageMapper(BytesMessageMapper messageMapper) Provide aBytesMessageMapperto convert to/from messages when send or receive happens on the sockets.static ZeroMqChannelSpecZeroMq.pubSubZeroMqChannel(org.zeromq.ZContext context) Create an instance ofZeroMqChannelSpecin pub/sub mode based on the providedZContext.ZeroMqChannelSpec.sendSocketConfigurer(Consumer<org.zeromq.ZMQ.Socket> sendSocketConfigurer) TheConsumercallback to configure a publishing socket.ZeroMqChannelSpec.subscribeSocketConfigurer(Consumer<org.zeromq.ZMQ.Socket> subscribeSocketConfigurer) TheConsumercallback to configure a consuming socket.static ZeroMqChannelSpecZeroMq.zeroMqChannel(org.zeromq.ZContext context) Create an instance ofZeroMqChannelSpecbased on the providedZContext.ZeroMqChannelSpec.zeroMqProxy(ZeroMqProxy zeroMqProxy) Specify a reference to aZeroMqProxyinstance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started.