Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec

Packages that use ZeroMqMessageHandlerSpec

Package	Description
org.springframework.integration.zeromq.dsl	Provides classes for supporting ZeroMQ component via Java DSL.

Uses of ZeroMqMessageHandlerSpec in org.springframework.integration.zeromq.dsl

Methods in org.springframework.integration.zeromq.dsl that return ZeroMqMessageHandlerSpec

Modifier and Type	Method	Description
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.messageConverter(MessageConverter messageConverter)	Provide a MessageConverter (as an alternative to messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)) for converting a request message into byte[] for sending into ZeroMq socket.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.messageMapper(OutboundMessageMapper<byte[]> messageMapper)	Provide an OutboundMessageMapper to convert a request message into byte[] for sending into ZeroMq socket.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, int port)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and binding port.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, int port, org.zeromq.SocketType socketType)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, binding port and SocketType.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL.
static ZeroMqMessageHandlerSpec	ZeroMq.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 ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and connection URL supplier.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL supplier and SocketType.
static ZeroMqMessageHandlerSpec	ZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType)	Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext and SocketType.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.socketConfigurer(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer)	Provide a Consumer to configure a socket with arbitrary options, like security.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.topic(String topic)	Specify a topic the SocketType.PUB socket is going to use for distributing messages into the subscriptions.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.topicExpression(String topicExpression)	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.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.topicExpression(Expression topicExpression)	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.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.topicFunction(Function<Message<?>,String> topicFunction)	Specify a Function 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.
ZeroMqMessageHandlerSpec	ZeroMqMessageHandlerSpec.wrapTopic(boolean wrapTopic)	Specify if the topic that SocketType.PUB socket is going to use for distributing messages into the subscriptions must be wrapped with an additional empty frame.