Class SyslogReceivingChannelAdapterSupport
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.syslog.inbound.SyslogReceivingChannelAdapterSupport
- All Implemented Interfaces:
Aware
,BeanFactoryAware
,BeanNameAware
,DisposableBean
,InitializingBean
,SmartInitializingSingleton
,ApplicationContextAware
,Lifecycle
,Phased
,SmartLifecycle
,ExpressionCapable
,MessageProducer
,IntegrationPattern
,NamedComponent
,ManageableLifecycle
,ManageableSmartLifecycle
,TrackableComponent
- Direct Known Subclasses:
TcpSyslogReceivingChannelAdapter
,UdpSyslogReceivingChannelAdapter
public abstract class SyslogReceivingChannelAdapterSupport extends MessageProducerSupport
Base support class for inbound channel adapters. The default port is 514.
- Since:
- 3.0
- Author:
- Gary Russell
-
Field Summary
Fields Modifier and Type Field Description protected static int
DEFAULT_PORT
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger
-
Constructor Summary
Constructors Constructor Description SyslogReceivingChannelAdapterSupport()
-
Method Summary
Modifier and Type Method Description protected void
convertAndSend(Message<?> message)
protected int
getPort()
protected void
onInit()
Subclasses may implement this for initialization logic.void
setConverter(MessageConverter converter)
AMessageConverter
to convert the byte array payload of the underlying UDP/TCP message to a Spring Integration message with decoded payload and headers; default isDefaultMessageConverter
.void
setPort(int port)
Sets the port on which the adapter listens; default is 514; note that the RFC does not specify a well known port for TCP; 514 is the well-known port for UDP.Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, 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
getBeanName, getComponentName, getComponentType
-
Field Details
-
DEFAULT_PORT
protected static final int DEFAULT_PORT- See Also:
- Constant Field Values
-
-
Constructor Details
-
SyslogReceivingChannelAdapterSupport
public SyslogReceivingChannelAdapterSupport()
-
-
Method Details
-
getPort
protected int getPort()- Returns:
- The port on which this adapter listens.
-
setPort
public void setPort(int port)Sets the port on which the adapter listens; default is 514; note that the RFC does not specify a well known port for TCP; 514 is the well-known port for UDP. Many admins also use 514 for TCP; see RFC-6587 for more information about TCP and RFC-3164/5424 for more information about UDP.- Parameters:
port
- The port.
-
setConverter
AMessageConverter
to convert the byte array payload of the underlying UDP/TCP message to a Spring Integration message with decoded payload and headers; default isDefaultMessageConverter
.- Parameters:
converter
- The converter.
-
onInit
protected void onInit()Description copied from class:IntegrationObjectSupport
Subclasses may implement this for initialization logic.- Overrides:
onInit
in classMessageProducerSupport
-
convertAndSend
-