Class ZeroMqChannelSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.dsl.MessageChannelSpec<ZeroMqChannelSpec,ZeroMqChannel>
org.springframework.integration.zeromq.dsl.ZeroMqChannelSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<ZeroMqChannel>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.dsl.ComponentsRegistration
public class ZeroMqChannelSpec
extends org.springframework.integration.dsl.MessageChannelSpec<ZeroMqChannelSpec,ZeroMqChannel>
The
MessageChannelSpec for a ZeroMqChannel.- Since:
- 5.4
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.MessageChannelSpec
channelFields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, targetFields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
loggerFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedZeroMqChannelSpec(org.zeromq.ZContext context, boolean pubSub) -
Method Summary
Modifier and TypeMethodDescriptionconnectUrl(String connectUrl) Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets.consumeDelay(Duration consumeDelay) Specify aDurationto delay consumption when no data received.messageMapper(org.springframework.integration.mapping.BytesMessageMapper messageMapper) Provide aBytesMessageMapperto convert to/from messages when send or receive happens on the sockets.sendSocketConfigurer(Consumer<org.zeromq.ZMQ.Socket> sendSocketConfigurer) TheConsumercallback to configure a publishing socket.subscribeSocketConfigurer(Consumer<org.zeromq.ZMQ.Socket> subscribeSocketConfigurer) TheConsumercallback to configure a consuming socket.zeroMqProxy(ZeroMqProxy zeroMqProxy) Specify a reference to aZeroMqProxyinstance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started.Methods inherited from class org.springframework.integration.dsl.MessageChannelSpec
datatype, doGet, getComponentsToRegister, interceptor, messageConverter, wireTap, wireTap, wireTapMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopMethods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
-
Constructor Details
-
ZeroMqChannelSpec
protected ZeroMqChannelSpec(org.zeromq.ZContext context, boolean pubSub)
-
-
Method Details
-
connectUrl
Configure a connection to the ZeroMQ proxy with the pair of ports over colon for proxy frontend and backend sockets. Mutually exclusive with thezeroMqProxy(ZeroMqProxy).- Parameters:
connectUrl- the connection string in formatPROTOCOL://HOST:FRONTEND_PORT:BACKEND_PORT, e.g.tcp://localhost:6001:6002- Returns:
- the spec
-
zeroMqProxy
Specify a reference to aZeroMqProxyinstance in the same application to rely on its ports configuration and make a natural lifecycle dependency without guessing when the proxy is started. Mutually exclusive with theconnectUrl(String).- Parameters:
zeroMqProxy- theZeroMqProxyinstance to use- Returns:
- the spec
-
consumeDelay
Specify aDurationto delay consumption when no data received.- Parameters:
consumeDelay- theDurationto delay consumption when empty; defaults toZeroMqChannel.DEFAULT_CONSUME_DELAY.- Returns:
- the spec
-
messageMapper
public ZeroMqChannelSpec messageMapper(org.springframework.integration.mapping.BytesMessageMapper messageMapper) Provide aBytesMessageMapperto convert to/from messages when send or receive happens on the sockets.- Parameters:
messageMapper- theBytesMessageMapperto use.- Returns:
- the spec
-
sendSocketConfigurer
TheConsumercallback to configure a publishing socket.- Parameters:
sendSocketConfigurer- theConsumerto use.- Returns:
- the spec
-
subscribeSocketConfigurer
public ZeroMqChannelSpec subscribeSocketConfigurer(Consumer<org.zeromq.ZMQ.Socket> subscribeSocketConfigurer) TheConsumercallback to configure a consuming socket.- Parameters:
subscribeSocketConfigurer- theConsumerto use.- Returns:
- the spec
-