Uses of Class
org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
Packages that use ZeroMqMessageHandlerSpec
Package
Description
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 ZeroMqMessageHandlerSpecModifier 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
.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.