Index
A B C D G H I M O P R S T U V Z
All Classes|All Packages
All Classes|All Packages
All Classes|All Packages
A
- afterPropertiesSet() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
B
- bindPort(int) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Configure a port for TCP protocol binding via
ZMQ.Socket.bind(String).
C
- connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.
- connectUrl(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Configure an URL for
ZMQ.Socket.connect(String). - consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
Specify a
Durationto delay consumption when no data received. - consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Specify a
Durationto delay consumption when no data received.
D
- DEFAULT_CONSUME_DELAY - Static variable in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- DEFAULT_CONSUME_DELAY - Static variable in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- destroy() - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- destroy() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- destroy() - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
- destroy() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- doSend(Message<?>, long) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- doStart() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- doStop() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
G
- getBackendPort() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Return the port a backend socket is bound or null if this proxy has not been started yet.
- getBackendSocketType() - Method in enum org.springframework.integration.zeromq.ZeroMqProxy.Type
- getBoundPort() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Return the port a socket is bound or 0 if this message producer has not been started yet or the socket is connected - not bound.
- getCaptureAddress() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Return the address an
inproccapture socket is bound or null if this proxy has not been started yet orZeroMqProxy.captureAddressis false. - getComponentType() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- getComponentType() - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
- getControlAddress() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Return the address an
inproccontrol socket is bound or null if this proxy has not been started yet. - getFrontendPort() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Return the port a frontend socket is bound or 0 if this proxy has not been started yet.
- getFrontendSocketType() - Method in enum org.springframework.integration.zeromq.ZeroMqProxy.Type
- getPhase() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- getType() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
H
- handleMessageInternal(Message<?>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
I
- inboundChannelAdapter(ZContext) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqMessageProducerSpecfor the providedZContext. - inboundChannelAdapter(ZContext, SocketType) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
- isAutoStartup() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- isRunning() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
M
- messageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Provide a
MessageConverter(as an alternative toZeroMqMessageHandlerSpec.messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)) for converting a request message intobyte[]for sending into ZeroMq socket. - messageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Provide a
MessageConverter(as an alternative toZeroMqMessageProducerSpec.messageMapper(org.springframework.integration.mapping.InboundMessageMapper<byte[]>)) for converting a consumed data into a message to produce. - messageMapper(BytesMessageMapper) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
Provide a
BytesMessageMapperto convert to/from messages when send or receive happens on the sockets. - messageMapper(InboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Provide an
InboundMessageMapperto convert a consumed data into a message to produce. - messageMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Provide an
OutboundMessageMapperto convert a request message intobyte[]for sending into ZeroMq socket.
O
- onInit() - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- onInit() - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- onInit() - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
- org.springframework.integration.zeromq - package org.springframework.integration.zeromq
-
Provides common classes for supporting ZeroMQ components.
- org.springframework.integration.zeromq.channel - package org.springframework.integration.zeromq.channel
-
Provides classes for message channels support over ZeroMQ.
- org.springframework.integration.zeromq.dsl - package org.springframework.integration.zeromq.dsl
-
Provides classes for supporting ZeroMQ component via Java DSL.
- org.springframework.integration.zeromq.inbound - package org.springframework.integration.zeromq.inbound
-
Provides classes for inbound channel adapters over ZeroMQ.
- org.springframework.integration.zeromq.outbound - package org.springframework.integration.zeromq.outbound
-
Provides classes for outbound channel adapters over ZeroMQ.
- outboundChannelAdapter(ZContext, String) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqMessageHandlerSpecfor the providedZContextand connection URL. - outboundChannelAdapter(ZContext, String, SocketType) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqMessageHandlerSpecfor the providedZContext, connection URL andSocketType.
P
- PREFIX - Static variable in class org.springframework.integration.zeromq.ZeroMqHeaders
- pubSubZeroMqChannel(ZContext) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqChannelSpecin pub/sub mode based on the providedZContext. - PULL_PUSH - org.springframework.integration.zeromq.ZeroMqProxy.Type
R
- receiveRaw(boolean) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Whether raw
ZMsgis present as a payload of message to produce or it is fully converted to aMessageincludingZeroMqHeaders.TOPICheader (if any). - ROUTER_DEALER - org.springframework.integration.zeromq.ZeroMqProxy.Type
S
- sendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
The
Consumercallback to configure a publishing socket. - setAutoStartup(boolean) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- setBackendPort(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Specify a fixed port for backend socket of the proxy.
- setBackendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Provide a
Consumerto configure a proxy backend socket with arbitrary options, like security. - setBeanName(String) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- setBindPort(int) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Configure a port for TCP protocol binding via
ZMQ.Socket.bind(String). - setConnectUrl(String) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.
- setConnectUrl(String) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Configure an URL for
ZMQ.Socket.connect(String). - setConsumeDelay(Duration) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Specify a
Durationto delay consumption when no data received. - setConsumeDelay(Duration) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Specify a
Durationto delay consumption when no data received. - setExposeCaptureSocket(boolean) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Whether to bind and expose a capture socket for the proxy data.
- setFrontendPort(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Specify a fixed port for frontend socket of the proxy.
- setFrontendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Provide a
Consumerto configure a proxy frontend socket with arbitrary options, like security. - setMessageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Provide a
MessageConverter(as an alternative toZeroMqMessageProducer.messageMapper) for converting a consumed data into a message to produce. - setMessageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide a
MessageConverter(as an alternative toZeroMqMessageHandler.messageMapper) for converting a request message intobyte[]for sending into ZeroMq socket. - setMessageMapper(BytesMessageMapper) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Provide a
BytesMessageMapperto convert to/from messages when send or receive happens on the sockets. - setMessageMapper(InboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Provide an
InboundMessageMapperto convert a consumed data into a message to produce. - setMessageMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide an
OutboundMessageMapperto convert a request message intobyte[]for sending into ZeroMq socket. - setPhase(int) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- setProxyExecutor(Executor) - Method in class org.springframework.integration.zeromq.ZeroMqProxy
-
Configure an executor to perform a ZeroMQ proxy loop.
- setReceiveRaw(boolean) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Whether raw
ZMsgis present as a payload of message to produce or it is fully converted to aMessageincludingZeroMqHeaders.TOPICheader (if any). - setSendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
The
Consumercallback to configure a publishing socket. - setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Provide a
Consumerto configure a socket with arbitrary options, like security. - setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Provide a
Consumerto configure a socket with arbitrary options, like security. - setSubscribeSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
The
Consumercallback to configure a consuming socket. - setTopic(String) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Specify a topic the
SocketType.PUBsocket is going to use for distributing messages into the subscriptions. - setTopicExpression(Expression) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Specify a SpEL expression to evaluate a topic a
SocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported. - setTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
-
Specify topics the
SocketType.SUBsocket is going to use for subscription. - setZeroMqProxy(ZeroMqProxy) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Specify a reference to a
ZeroMqProxyinstance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started. - socketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Provide a
Consumerto configure a socket with arbitrary options, like security. - socketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Provide a
Consumerto configure a socket with arbitrary options, like security. - start() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- stop() - Method in class org.springframework.integration.zeromq.ZeroMqProxy
- SUB_PUB - org.springframework.integration.zeromq.ZeroMqProxy.Type
- subscribe(MessageHandler) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- subscribeSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
The
Consumercallback to configure a consuming socket. - subscribeToTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
T
- topic(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Specify a topic the
SocketType.PUBsocket is going to use for distributing messages into the subscriptions. - TOPIC - Static variable in class org.springframework.integration.zeromq.ZeroMqHeaders
-
A ZeroMq pub/sub message topic header.
- topicExpression(String) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Specify a SpEL expression to evaluate a topic a
SocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported. - topicExpression(Expression) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Specify a SpEL expression to evaluate a topic a
SocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported. - topicFunction(Function<Message<?>, String>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Specify a
Functionto evaluate a topic aSocketType.PUBis going to use for distributing messages into the subscriptions.It is ignored for all otherSocketTypes supported. - topics(String...) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
-
Specify topics the
SocketType.SUBsocket is going to use for subscription.
U
- unsubscribe(MessageHandler) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
- unsubscribeFromTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
V
- valueOf(String) - Static method in enum org.springframework.integration.zeromq.ZeroMqProxy.Type
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.springframework.integration.zeromq.ZeroMqProxy.Type
-
Returns an array containing the constants of this enum type, in the order they are declared.
Z
- ZeroMq - Class in org.springframework.integration.zeromq.dsl
-
Factory class for ZeroMq components DSL.
- zeroMqChannel(ZContext) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
-
Create an instance of
ZeroMqChannelSpecbased on the providedZContext. - ZeroMqChannel - Class in org.springframework.integration.zeromq.channel
-
The
SubscribableChannelimplementation over ZeroMQ sockets. - ZeroMqChannel(ZContext) - Constructor for class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Create a channel instance based on the provided
ZContextwith push/pull communication model. - ZeroMqChannel(ZContext, boolean) - Constructor for class org.springframework.integration.zeromq.channel.ZeroMqChannel
-
Create a channel instance based on the provided
ZContextand provided communication model. - ZeroMqChannelSpec - Class in org.springframework.integration.zeromq.dsl
-
The
MessageChannelSpecfor aZeroMqChannel. - ZeroMqChannelSpec(ZContext, boolean) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
- ZeroMqHeaders - Class in org.springframework.integration.zeromq
-
The message headers constants to repsent ZeroMq message attributes.
- ZeroMqMessageHandler - Class in org.springframework.integration.zeromq.outbound
-
The
AbstractReactiveMessageHandlerimplementation for publishing messages over ZeroMq socket. - ZeroMqMessageHandler(ZContext, String) - Constructor for class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Create an instance based on the provided
ZContextand connection string. - ZeroMqMessageHandler(ZContext, String, SocketType) - Constructor for class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
-
Create an instance based on the provided
ZContext, connection string andSocketType. - ZeroMqMessageHandlerSpec - Class in org.springframework.integration.zeromq.dsl
-
The
ReactiveMessageHandlerSpecextension forZeroMqMessageHandler. - ZeroMqMessageHandlerSpec(ZContext, String) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Create an instance based on the provided
ZContextand connection string. - ZeroMqMessageHandlerSpec(ZContext, String, SocketType) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
-
Create an instance based on the provided
ZContext, connection string andSocketType. - ZeroMqMessageProducer - Class in org.springframework.integration.zeromq.inbound
-
A
MessageProducerSupportimplementation for consuming messages from ZeroMq socket. - ZeroMqMessageProducer(ZContext) - Constructor for class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- ZeroMqMessageProducer(ZContext, SocketType) - Constructor for class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
- ZeroMqMessageProducerSpec - Class in org.springframework.integration.zeromq.dsl
- ZeroMqMessageProducerSpec(ZContext) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
- ZeroMqMessageProducerSpec(ZContext, SocketType) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
- zeroMqProxy(ZeroMqProxy) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
-
Specify a reference to a
ZeroMqProxyinstance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started. - ZeroMqProxy - Class in org.springframework.integration.zeromq
-
This class encapsulates the logic to configure and manage a ZeroMQ proxy.
- ZeroMqProxy(ZContext) - Constructor for class org.springframework.integration.zeromq.ZeroMqProxy
- ZeroMqProxy(ZContext, ZeroMqProxy.Type) - Constructor for class org.springframework.integration.zeromq.ZeroMqProxy
- ZeroMqProxy.Type - Enum in org.springframework.integration.zeromq
All Classes|All Packages