org.springframework.xd.integration.reactor.syslog

Class SyslogInboundChannelAdapter

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<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

org.springframework.xd.integration.reactor.syslog.SyslogInboundChannelAdapter

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.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent

public class SyslogInboundChannelAdapter
extends ReactorPeerInboundChannelAdapter<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

InboundChannelAdapter implementation that uses the Reactor TCP support to read in syslog messages and transform them to a Map for use in downstream modules.

Author:

Jon Brisbin, 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
SyslogInboundChannelAdapter(reactor.io.net.ReactorPeer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer,reactor.io.net.ChannelStream<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>> server)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	composeChannel(reactor.io.net.ChannelStream<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> input)
java.lang.String	getComponentType()

Methods inherited from class org.springframework.xd.integration.reactor.net.ReactorPeerInboundChannelAdapter

doStart, doStop

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

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

SyslogInboundChannelAdapter

public SyslogInboundChannelAdapter(reactor.io.net.ReactorPeer<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer,reactor.io.net.ChannelStream<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>> server)

Method Detail

getComponentType

public java.lang.String getComponentType()

Specified by:

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

Overrides:

getComponentType in class ReactorPeerInboundChannelAdapter<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>

composeChannel

protected void composeChannel(reactor.io.net.ChannelStream<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer> input)

Overrides:

composeChannel in class ReactorPeerInboundChannelAdapter<reactor.io.buffer.Buffer,reactor.io.buffer.Buffer>