public class TcpOutboundGateway extends AbstractReplyProducingMessageHandler implements TcpSender, TcpListener, org.springframework.context.SmartLifecycle
SmartLifecycle methods delegate to the underlying AbstractConnectionFactory
AbstractReplyProducingMessageHandler.RequestHandlerlogger| Constructor and Description |
|---|
TcpOutboundGateway() |
| Modifier and Type | Method and Description |
|---|---|
void |
addNewConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener, this
method is called each time a new connection is made. |
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected AbstractConnectionFactory |
getConnectionFactory() |
int |
getPhase() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
boolean |
isAutoStartup() |
boolean |
isRunning() |
boolean |
onMessage(org.springframework.messaging.Message<?> message)
Called by a TCPConnection when a new message arrives.
|
void |
removeDeadConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener, this
method is called each time a connection is closed. |
void |
setAutoStartup(boolean autoStartup) |
void |
setConnectionFactory(AbstractConnectionFactory connectionFactory) |
void |
setPhase(int phase) |
void |
setRemoteTimeout(long remoteTimeout) |
void |
setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)
Specify the Spring Integration reply channel.
|
void |
setRequestTimeout(long requestTimeout) |
void |
setSendTimeout(long sendTimeout)
Set the timeout for sending reply Messages.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
doInit, doInvokeAdvisedRequestHandler, getMessagingTemplate, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setChannelResolver, setOutputChannel, setRequiresReply, shouldCopyRequestHeadersgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic void setRequestTimeout(long requestTimeout)
requestTimeout - the requestTimeout to setpublic void setRemoteTimeout(long remoteTimeout)
remoteTimeout - the remoteTimeout to setpublic void setSendTimeout(long sendTimeout)
AbstractReplyProducingMessageHandlersetSendTimeout in class AbstractReplyProducingMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
AbstractReplyProducingMessageHandlerhandleRequestMessage in class AbstractReplyProducingMessageHandlerpublic boolean onMessage(org.springframework.messaging.Message<?> message)
TcpListeneronMessage in interface TcpListenermessage - The message.public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
public void addNewConnection(TcpConnection connection)
TcpSenderTcpListener, this
method is called each time a new connection is made.addNewConnection in interface TcpSenderconnection - The connection.public void removeDeadConnection(TcpConnection connection)
TcpSenderTcpListener, this
method is called each time a connection is closed.removeDeadConnection in interface TcpSenderconnection - The connection.public void setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)
public java.lang.String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class AbstractMessageHandlerpublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic int getPhase()
getPhase in interface org.springframework.context.Phasedpublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
protected AbstractConnectionFactory getConnectionFactory()