org.springframework.integration.ip.tcp
Class TcpReceivingChannelAdapter
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.tcp.TcpReceivingChannelAdapter
- All Implemented Interfaces:
- BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent, MessageProducer, TrackableComponent, TcpListener
public class TcpReceivingChannelAdapter
- extends MessageProducerSupport
- implements TcpListener
Tcp inbound channel adapter using a TcpConnection to
receive data - if the connection factory is a server
factory, this Listener owns the connections. If it is
a client factory, the sender owns the connection.
- Since:
- 2.0
Method Summary |
protected void |
doStart()
Takes no action by default. |
protected void |
doStop()
Takes no action by default. |
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information. |
boolean |
isListening()
|
boolean |
onMessage(Message<?> message)
Called by a TCPConnection when a new message arrives. |
void |
setConnectionFactory(AbstractConnectionFactory connectionFactory)
Sets the client or server connection factory; for this (an inbound adapter), if
the factory is a client connection factory, the sockets are owned by a sending
channel adapter and this adapter is used to receive replies. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
serverSocket
protected java.net.ServerSocket serverSocket
clientConnectionFactory
protected ConnectionFactory clientConnectionFactory
serverConnectionFactory
protected ConnectionFactory serverConnectionFactory
TcpReceivingChannelAdapter
public TcpReceivingChannelAdapter()
onMessage
public boolean onMessage(Message<?> message)
- Description copied from interface:
TcpListener
- Called by a TCPConnection when a new message arrives.
- Specified by:
onMessage
in interface TcpListener
- Parameters:
message
- The message.
- Returns:
- true if the message was intercepted
doStart
protected void doStart()
- Description copied from class:
MessageProducerSupport
- Takes no action by default. Subclasses may override this if they
need lifecycle-managed behavior.
- Overrides:
doStart
in class MessageProducerSupport
doStop
protected void doStop()
- Description copied from class:
MessageProducerSupport
- Takes no action by default. Subclasses may override this if they
need lifecycle-managed behavior.
- Overrides:
doStop
in class MessageProducerSupport
setConnectionFactory
public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
- Sets the client or server connection factory; for this (an inbound adapter), if
the factory is a client connection factory, the sockets are owned by a sending
channel adapter and this adapter is used to receive replies.
- Parameters:
connectionFactory
- the connectionFactory to set
isListening
public boolean isListening()
getComponentType
public java.lang.String getComponentType()
- Description copied from class:
IntegrationObjectSupport
- Subclasses may implement this method to provide component type information.
- Specified by:
getComponentType
in interface NamedComponent
- Overrides:
getComponentType
in class IntegrationObjectSupport