Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
Package
Description
Provides classes for supporting ZeroMQ component via Java DSL.
-
Uses of ZeroMqMessageHandlerSpec in org.springframework.integration.zeromq.dsl
Modifier and TypeMethodDescriptionZeroMqMessageHandlerSpec.messageConverter
(MessageConverter messageConverter) Provide aMessageConverter
(as an alternative tomessageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)
) for converting a request message intobyte[]
for sending into ZeroMq socket.ZeroMqMessageHandlerSpec.messageMapper
(OutboundMessageMapper<byte[]> messageMapper) Provide anOutboundMessageMapper
to convert a request message intobyte[]
for sending into ZeroMq socket.static ZeroMqMessageHandlerSpec
ZeroMq.outboundChannelAdapter
(org.zeromq.ZContext context, String connectUrl) Create an instance ofZeroMqMessageHandlerSpec
for the providedZContext
and connection URL.static ZeroMqMessageHandlerSpec
ZeroMq.outboundChannelAdapter
(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType) Create an instance ofZeroMqMessageHandlerSpec
for the providedZContext
, connection URL andSocketType
.static ZeroMqMessageHandlerSpec
ZeroMq.outboundChannelAdapter
(org.zeromq.ZContext context, Supplier<String> connectUrl) Create an instance ofZeroMqMessageHandlerSpec
for the providedZContext
and connection URL supplier.static ZeroMqMessageHandlerSpec
ZeroMq.outboundChannelAdapter
(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType) Create an instance ofZeroMqMessageHandlerSpec
for the providedZContext
, connection URL supplier andSocketType
.ZeroMqMessageHandlerSpec.socketConfigurer
(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer) Provide aConsumer
to configure a socket with arbitrary options, like security.Specify a topic theSocketType.PUB
socket is going to use for distributing messages into the subscriptions.ZeroMqMessageHandlerSpec.topicExpression
(String topicExpression) Specify a SpEL expression to evaluate a topic aSocketType.PUB
is going to use for distributing messages into the subscriptions.It is ignored for all otherSocketType
s supported.ZeroMqMessageHandlerSpec.topicExpression
(Expression topicExpression) Specify a SpEL expression to evaluate a topic aSocketType.PUB
is going to use for distributing messages into the subscriptions.It is ignored for all otherSocketType
s supported.ZeroMqMessageHandlerSpec.topicFunction
(Function<Message<?>, String> topicFunction) Specify aFunction
to evaluate a topic aSocketType.PUB
is going to use for distributing messages into the subscriptions.It is ignored for all otherSocketType
s supported.ZeroMqMessageHandlerSpec.wrapTopic
(boolean wrapTopic) Specify if the topic thatSocketType.PUB
socket is going to use for distributing messages into the subscriptions must be wrapped with an additional empty frame.