Index

A B C D G H I M O P R S T U V Z 
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 Duration to delay consumption when no data received.
consumeDelay(Duration) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
Specify a Duration to 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 inproc capture socket is bound or null if this proxy has not been started yet or ZeroMqProxy.captureAddress is 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 inproc control 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 ZeroMqMessageProducerSpec for the provided ZContext.
inboundChannelAdapter(ZContext, SocketType) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
Create an instance of ZeroMqMessageProducerSpec for the provided ZContext and SocketType.
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 to ZeroMqMessageHandlerSpec.messageMapper(org.springframework.integration.mapping.OutboundMessageMapper<byte[]>)) for converting a request message into byte[] for sending into ZeroMq socket.
messageConverter(MessageConverter) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
Provide a MessageConverter (as an alternative to ZeroMqMessageProducerSpec.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 BytesMessageMapper to 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 InboundMessageMapper to convert a consumed data into a message to produce.
messageMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
Provide an OutboundMessageMapper to convert a request message into byte[] 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 ZeroMqMessageHandlerSpec for the provided ZContext and connection URL.
outboundChannelAdapter(ZContext, String, SocketType) - Static method in class org.springframework.integration.zeromq.dsl.ZeroMq
Create an instance of ZeroMqMessageHandlerSpec for the provided ZContext, connection URL and SocketType.

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 ZeroMqChannelSpec in pub/sub mode based on the provided ZContext.
PULL_PUSH - org.springframework.integration.zeromq.ZeroMqProxy.Type
 

R

receiveRaw(boolean) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
Whether raw ZMsg is present as a payload of message to produce or it is fully converted to a Message including ZeroMqHeaders.TOPIC header (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 Consumer callback 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 Consumer to 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 Duration to delay consumption when no data received.
setConsumeDelay(Duration) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
Specify a Duration to 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 Consumer to 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 to ZeroMqMessageProducer.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 to ZeroMqMessageHandler.messageMapper) for converting a request message into byte[] for sending into ZeroMq socket.
setMessageMapper(BytesMessageMapper) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
Provide a BytesMessageMapper to 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 InboundMessageMapper to convert a consumed data into a message to produce.
setMessageMapper(OutboundMessageMapper<byte[]>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
Provide an OutboundMessageMapper to convert a request message into byte[] 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 ZMsg is present as a payload of message to produce or it is fully converted to a Message including ZeroMqHeaders.TOPIC header (if any).
setSendSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
The Consumer callback to configure a publishing socket.
setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
Provide a Consumer to configure a socket with arbitrary options, like security.
setSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
Provide a Consumer to configure a socket with arbitrary options, like security.
setSubscribeSocketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
The Consumer callback to configure a consuming socket.
setTopic(String) - Method in class org.springframework.integration.zeromq.outbound.ZeroMqMessageHandler
Specify a topic the SocketType.PUB socket 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.PUB is going to use for distributing messages into the subscriptions.It is ignored for all other SocketTypes supported.
setTopics(String...) - Method in class org.springframework.integration.zeromq.inbound.ZeroMqMessageProducer
Specify topics the SocketType.SUB socket is going to use for subscription.
setZeroMqProxy(ZeroMqProxy) - Method in class org.springframework.integration.zeromq.channel.ZeroMqChannel
Specify a reference to a ZeroMqProxy instance 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 Consumer to configure a socket with arbitrary options, like security.
socketConfigurer(Consumer<ZMQ.Socket>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
Provide a Consumer to 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 Consumer callback 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.PUB socket 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.PUB is going to use for distributing messages into the subscriptions.It is ignored for all other SocketTypes supported.
topicExpression(Expression) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
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.
topicFunction(Function<Message<?>, String>) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
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.
topics(String...) - Method in class org.springframework.integration.zeromq.dsl.ZeroMqMessageProducerSpec
Specify topics the SocketType.SUB socket 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 ZeroMqChannelSpec based on the provided ZContext.
ZeroMqChannel - Class in org.springframework.integration.zeromq.channel
The SubscribableChannel implementation over ZeroMQ sockets.
ZeroMqChannel(ZContext) - Constructor for class org.springframework.integration.zeromq.channel.ZeroMqChannel
Create a channel instance based on the provided ZContext with push/pull communication model.
ZeroMqChannel(ZContext, boolean) - Constructor for class org.springframework.integration.zeromq.channel.ZeroMqChannel
Create a channel instance based on the provided ZContext and provided communication model.
ZeroMqChannelSpec - Class in org.springframework.integration.zeromq.dsl
The MessageChannelSpec for a ZeroMqChannel.
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 AbstractReactiveMessageHandler implementation 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 ZContext and 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 and SocketType.
ZeroMqMessageHandlerSpec - Class in org.springframework.integration.zeromq.dsl
The ReactiveMessageHandlerSpec extension for ZeroMqMessageHandler.
ZeroMqMessageHandlerSpec(ZContext, String) - Constructor for class org.springframework.integration.zeromq.dsl.ZeroMqMessageHandlerSpec
Create an instance based on the provided ZContext and 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 and SocketType.
ZeroMqMessageProducer - Class in org.springframework.integration.zeromq.inbound
A MessageProducerSupport implementation 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 ZeroMqProxy instance 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
Create a ZeroMqProxy instance based on the provided ZContext and PULL_PUSH as default mode.
ZeroMqProxy(ZContext, ZeroMqProxy.Type) - Constructor for class org.springframework.integration.zeromq.ZeroMqProxy
Create a ZeroMqProxy instance based on the provided ZContext and ZeroMqProxy.Type.
ZeroMqProxy.Type - Enum in org.springframework.integration.zeromq
 
A B C D G H I M O P R S T U V Z 
All Classes|All Packages