public abstract class AbstractInternetProtocolReceivingChannelAdapter extends MessageProducerSupport implements java.lang.Runnable, CommonSocketOptions
logger| Constructor and Description |
|---|
AbstractInternetProtocolReceivingChannelAdapter(int port) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
checkTaskExecutor(java.lang.String threadName)
Creates a default task executor if none was supplied.
|
protected void |
doStart()
Protected by lifecycleLock
|
protected void |
doStop()
Takes no action by default.
|
java.lang.String |
getLocalAddress() |
int |
getPort() |
int |
getReceiveBufferSize() |
int |
getSoReceiveBufferSize() |
int |
getSoTimeout() |
java.util.concurrent.Executor |
getTaskExecutor() |
boolean |
isActive() |
boolean |
isListening() |
void |
setListening(boolean listening) |
void |
setLocalAddress(java.lang.String localAddress)
On a multi-homed system, specifies the ip address of the network interface used to communicate.
|
void |
setPoolSize(int poolSize) |
void |
setReceiveBufferSize(int receiveBufferSize) |
void |
setSoReceiveBufferSize(int soReceiveBufferSize) |
void |
setSoTimeout(int soTimeout) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsetSoSendBufferSizegetComponentName, getComponentTypepublic AbstractInternetProtocolReceivingChannelAdapter(int port)
public int getPort()
public void setSoTimeout(int soTimeout)
setSoTimeout in interface CommonSocketOptionsSocket.setSoTimeout(int),
DatagramSocket.setSoTimeout(int)public int getSoTimeout()
public void setSoReceiveBufferSize(int soReceiveBufferSize)
setSoReceiveBufferSize in interface CommonSocketOptionsSocket.setReceiveBufferSize(int),
DatagramSocket.setReceiveBufferSize(int)public int getSoReceiveBufferSize()
public void setReceiveBufferSize(int receiveBufferSize)
public int getReceiveBufferSize()
protected void doStart()
doStart in class MessageProducerSupportprotected void checkTaskExecutor(java.lang.String threadName)
threadName - protected void doStop()
MessageProducerSupportdoStop in class MessageProducerSupportpublic boolean isListening()
public void setListening(boolean listening)
listening - the listening to setpublic java.lang.String getLocalAddress()
public void setLocalAddress(java.lang.String localAddress)
CommonSocketOptionssetLocalAddress in interface CommonSocketOptionspublic void setPoolSize(int poolSize)
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public java.util.concurrent.Executor getTaskExecutor()
public boolean isActive()