Class ZeroMq
java.lang.Object
org.springframework.integration.zeromq.dsl.ZeroMq
public final class ZeroMq extends Object
Factory class for ZeroMq components DSL.
- Since:
- 5.4
- Author:
- Artem Bilan
-
Method Summary
Modifier and Type Method Description static ZeroMqMessageProducerSpecinboundChannelAdapter(org.zeromq.ZContext context)Create an instance ofZeroMqMessageProducerSpecfor the providedZContext.static ZeroMqMessageProducerSpecinboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)static ZeroMqMessageHandlerSpecoutboundChannelAdapter(org.zeromq.ZContext context, String connectUrl)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL.static ZeroMqMessageHandlerSpecoutboundChannelAdapter(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL andSocketType.static ZeroMqMessageHandlerSpecoutboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL supplier.static ZeroMqMessageHandlerSpecoutboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL supplier andSocketType.static ZeroMqChannelSpecpubSubZeroMqChannel(org.zeromq.ZContext context)Create an instance ofZeroMqChannelSpecin pub/sub mode based on the providedZContext.static ZeroMqChannelSpeczeroMqChannel(org.zeromq.ZContext context)Create an instance ofZeroMqChannelSpecbased on the providedZContext.
-
Method Details
-
zeroMqChannel
Create an instance ofZeroMqChannelSpecbased on the providedZContext.- Parameters:
context- theZContextto use.- Returns:
- the spec.
-
pubSubZeroMqChannel
Create an instance ofZeroMqChannelSpecin pub/sub mode based on the providedZContext.- Parameters:
context- theZContextto use.- Returns:
- the spec.
-
outboundChannelAdapter
public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL.- Parameters:
context- theZContextto use.connectUrl- the URL to connect a ZeroMq socket to.- Returns:
- the spec.
-
outboundChannelAdapter
public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL supplier.- Parameters:
context- theZContextto use.connectUrl- the supplier for URL to connect a ZeroMq socket to.- Returns:
- the spec.
- Since:
- 5.5.9
-
outboundChannelAdapter
public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL andSocketType.- Parameters:
context- theZContextto use.connectUrl- the URL to connect a ZeroMq socket to.socketType- theSocketTypefor ZeroMq socket.- Returns:
- the spec.
-
outboundChannelAdapter
public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType)Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL supplier andSocketType.- Parameters:
context- theZContextto use.connectUrl- the supplier for URL to connect a ZeroMq socket to.socketType- theSocketTypefor ZeroMq socket.- Returns:
- the spec.
- Since:
- 5.5.9
-
inboundChannelAdapter
Create an instance ofZeroMqMessageProducerSpecfor the providedZContext.- Parameters:
context- theZContextto use.- Returns:
- the spec.
-
inboundChannelAdapter
public static ZeroMqMessageProducerSpec inboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)- Parameters:
context- theZContextto use.socketType- theSocketTypefor ZeroMq socket.- Returns:
- the spec.
-