public class TcpConnectionEventListeningMessageProducer extends org.springframework.integration.endpoint.MessageProducerSupport implements org.springframework.context.ApplicationListener<TcpConnectionEvent>
MessageProducer
that produces Messages with @link TcpConnectionEvent
payloads.Constructor and Description |
---|
TcpConnectionEventListeningMessageProducer() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType() |
protected org.springframework.messaging.Message<TcpConnectionEvent> |
messageFromEvent(TcpConnectionEvent event) |
void |
onApplicationEvent(TcpConnectionEvent event) |
void |
setEventTypes(java.lang.Class<? extends TcpConnectionEvent>[] eventTypes)
Set the list of event types (classes that extend TcpConnectionEvent) that
this adapter should send to the message channel.
|
doStart, doStop, onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, getApplicationContext, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toString
public TcpConnectionEventListeningMessageProducer()
public void setEventTypes(java.lang.Class<? extends TcpConnectionEvent>[] eventTypes)
eventTypes
- The event types.public java.lang.String getComponentType()
getComponentType
in interface org.springframework.integration.support.context.NamedComponent
getComponentType
in class org.springframework.integration.context.IntegrationObjectSupport
public void onApplicationEvent(TcpConnectionEvent event)
onApplicationEvent
in interface org.springframework.context.ApplicationListener<TcpConnectionEvent>
protected org.springframework.messaging.Message<TcpConnectionEvent> messageFromEvent(TcpConnectionEvent event)