org.springframework.xd.integration.reactor.net

Class ReactorPeerInboundChannelAdapter<IN,OUT>

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.xd.integration.reactor.net.ReactorPeerInboundChannelAdapter<IN,OUT>

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.core.MessageProducer, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.TrackableComponent

Direct Known Subclasses:

SyslogInboundChannelAdapter

public class ReactorPeerInboundChannelAdapter<IN,OUT>
extends org.springframework.integration.endpoint.MessageProducerSupport

Inbound ChannelAdapter that uses ReactorPeer abstraction to provide high-speed TCP or UDP ingest.

Author:

Stephane Maldini

Field Summary

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
ReactorPeerInboundChannelAdapter(reactor.io.net.ReactorPeer<IN,OUT,reactor.io.net.ChannelStream<IN,OUT>> reactorPeer)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	composeChannel(reactor.io.net.ChannelStream<IN,OUT> input)
protected void	doStart()
protected void	doStop()
java.lang.String	getComponentType()

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

getMessagingTemplate, onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Constructor Detail

ReactorPeerInboundChannelAdapter

public ReactorPeerInboundChannelAdapter(reactor.io.net.ReactorPeer<IN,OUT,reactor.io.net.ChannelStream<IN,OUT>> reactorPeer)

Method Detail

getComponentType

public java.lang.String getComponentType()

Specified by:

getComponentType in interface org.springframework.integration.support.context.NamedComponent

Overrides:

getComponentType in class org.springframework.integration.context.IntegrationObjectSupport

doStart

protected void doStart()

Overrides:

doStart in class org.springframework.integration.endpoint.MessageProducerSupport

doStop

protected void doStop()

Overrides:

doStop in class org.springframework.integration.endpoint.MessageProducerSupport

composeChannel

protected void composeChannel(reactor.io.net.ChannelStream<IN,OUT> input)