public abstract class AbstractInternetProtocolReceivingChannelAdapter extends org.springframework.integration.endpoint.MessageProducerSupport implements org.springframework.scheduling.SchedulingAwareRunnable, CommonSocketOptions
| 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() |
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) |
afterSingletonsInstantiated, getErrorChannel, getMessagingTemplate, getOutputChannel, onInit, sendMessage, setErrorChannel, setErrorChannelName, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrackdoStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitsetSoSendBufferSizepublic AbstractInternetProtocolReceivingChannelAdapter(int port)
public int getPort()
public void setSoTimeout(int soTimeout)
setSoTimeout in interface CommonSocketOptionssoTimeout - The timeout.Socket.setSoTimeout(int),
DatagramSocket.setSoTimeout(int)public int getSoTimeout()
public void setSoReceiveBufferSize(int soReceiveBufferSize)
setSoReceiveBufferSize in interface CommonSocketOptionssoReceiveBufferSize - The receive buffer size.Socket.setReceiveBufferSize(int),
DatagramSocket.setReceiveBufferSize(int)public int getSoReceiveBufferSize()
public void setReceiveBufferSize(int receiveBufferSize)
public int getReceiveBufferSize()
protected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void checkTaskExecutor(java.lang.String threadName)
threadName - The thread name.protected void doStop()
doStop in class org.springframework.integration.endpoint.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 CommonSocketOptionslocalAddress - The local address.public void setPoolSize(int poolSize)
public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public java.util.concurrent.Executor getTaskExecutor()
public boolean isActive()