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.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 org.springframework.integration.endpoint.MessageProducerSupport

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

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.core.Environment env)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
java.lang.String	getComponentType()
protected void	onInit()
void	setHost(java.lang.String host) Set hostname to bind this server to.
void	setPort(int port) Set port to bind this server to.
void	setTransport(java.lang.String transport) Set the transport to use.

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

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.core.Environment env)

Method Detail

setTransport

public void setTransport(java.lang.String transport)

Set the transport to use. Should be either 'tcp' or 'udp'.

Parameters:

transport - transport

setHost

public void setHost(java.lang.String host)

Set hostname to bind this server to.

Parameters:

host - hostname

setPort

public void setPort(int port)

Set port to bind this server to.

Parameters:

port - port

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

onInit

protected void onInit()

Overrides:

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

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