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
Subclasses with type arguments of type ZeroMqMessageHandlerSpec in org.springframework.integration.zeromq.dslModifier and TypeClassDescriptionclassTheReactiveMessageHandlerSpecextension forZeroMqMessageHandler.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 anOutboundMessageMapperto convert a request message intobyte[]for sending into ZeroMq socket.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, int port) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand binding port.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, int port, org.zeromq.SocketType socketType) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, binding port andSocketType.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, String connectUrl, org.zeromq.SocketType socketType) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL andSocketType.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContextand connection URL supplier.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, Supplier<String> connectUrl, org.zeromq.SocketType socketType) Create an instance ofZeroMqMessageHandlerSpecfor the providedZContext, connection URL supplier andSocketType.static ZeroMqMessageHandlerSpecZeroMq.outboundChannelAdapter(org.zeromq.ZContext context, org.zeromq.SocketType socketType) ZeroMqMessageHandlerSpec.socketConfigurer(Consumer<org.zeromq.ZMQ.Socket> socketConfigurer) Provide aConsumerto configure a socket with arbitrary options, like security.Specify a topic theSocketType.PUBsocket is going to use for distributing messages into the subscriptions.ZeroMqMessageHandlerSpec.topicExpression(String topicExpression) Specify a SpEL expression to evaluate a topic aSocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported.ZeroMqMessageHandlerSpec.topicExpression(Expression topicExpression) Specify a SpEL expression to evaluate a topic aSocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported.ZeroMqMessageHandlerSpec.topicFunction(Function<Message<?>, String> topicFunction) Specify aFunctionto evaluate a topic aSocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported.ZeroMqMessageHandlerSpec.wrapTopic(boolean wrapTopic) Specify if the topic thatSocketType.PUBsocket is going to use for distributing messages into the subscriptions must be wrapped with an additional empty frame.