org.springframework.integration.zeromq.dsl

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 and Description
static ZeroMqMessageProducerSpec	inboundChannelAdapter(org.zeromq.ZContext context) Create an instance of ZeroMqMessageProducerSpec for the provided ZContext.
static ZeroMqMessageProducerSpec	inboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType) Create an instance of ZeroMqMessageProducerSpec for the provided ZContext and SocketType.
static ZeroMqMessageHandlerSpec	outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl) Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL.
static ZeroMqMessageHandlerSpec	outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType) Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL and SocketType.
static ZeroMqChannelSpec	pubSubZeroMqChannel(org.zeromq.ZContext context) Create an instance of ZeroMqChannelSpec in pub/sub mode based on the provided ZContext.
static ZeroMqChannelSpec	zeroMqChannel(org.zeromq.ZContext context) Create an instance of ZeroMqChannelSpec based on the provided ZContext.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

zeroMqChannel

public static ZeroMqChannelSpec zeroMqChannel(org.zeromq.ZContext context)

Create an instance of ZeroMqChannelSpec based on the provided ZContext.

Parameters:

context - the ZContext to use.

Returns:

the spec.

pubSubZeroMqChannel

public static ZeroMqChannelSpec pubSubZeroMqChannel(org.zeromq.ZContext context)

Create an instance of ZeroMqChannelSpec in pub/sub mode based on the provided ZContext.

Parameters:

context - the ZContext to use.

Returns:

the spec.

outboundChannelAdapter

public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context,
                                                              String connectUrl)

Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL.

Parameters:

context - the ZContext to use.

connectUrl - the URL to connect a ZeroMq socket to.

Returns:

the spec.

outboundChannelAdapter

public static ZeroMqMessageHandlerSpec outboundChannelAdapter(org.zeromq.ZContext context,
                                                              String connectUrl,
                                                              org.zeromq.SocketType socketType)

Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL and SocketType.

Parameters:

context - the ZContext to use.

connectUrl - the URL to connect a ZeroMq socket to.

socketType - the SocketType for ZeroMq socket.

Returns:

the spec.

inboundChannelAdapter

public static ZeroMqMessageProducerSpec inboundChannelAdapter(org.zeromq.ZContext context)

Create an instance of ZeroMqMessageProducerSpec for the provided ZContext.

Parameters:

context - the ZContext to use.

Returns:

the spec.

inboundChannelAdapter

public static ZeroMqMessageProducerSpec inboundChannelAdapter(org.zeromq.ZContext context,
                                                              org.zeromq.SocketType socketType)

Create an instance of ZeroMqMessageProducerSpec for the provided ZContext and SocketType.

Parameters:

context - the ZContext to use.

socketType - the SocketType for ZeroMq socket.

Returns:

the spec.