public class UnicastReceivingChannelAdapter extends AbstractInternetProtocolReceivingChannelAdapter
logger
Constructor and Description |
---|
UnicastReceivingChannelAdapter(int port)
Constructs a UnicastReceivingChannelAdapter that listens on the specified port.
|
UnicastReceivingChannelAdapter(int port,
boolean lengthCheck)
Constructs a UnicastReceivingChannelAdapter that listens for packets on
the specified port.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
asyncSendMessage(DatagramPacket packet) |
protected void |
doStop()
Takes no action by default.
|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected DatagramSocket |
getSocket() |
protected DatagramSocket |
getTheSocket() |
protected DatagramPacket |
receive() |
void |
run() |
protected void |
sendAck(Message<byte[]> message) |
void |
setLookupHost(boolean lookupHost) |
void |
setSocket(DatagramSocket socket) |
protected void |
setSocketAttributes(DatagramSocket socket)
Sets timeout and receive buffer size
|
void |
setSoSendBufferSize(int soSendBufferSize) |
checkTaskExecutor, doStart, getLocalAddress, getPort, getReceiveBufferSize, getSoReceiveBufferSize, getSoTimeout, getTaskExecutor, isActive, isListening, setListening, setLocalAddress, setPoolSize, setReceiveBufferSize, setSoReceiveBufferSize, setSoTimeout, setTaskExecutor
onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public UnicastReceivingChannelAdapter(int port)
port
- public UnicastReceivingChannelAdapter(int port, boolean lengthCheck)
port
- The port.lengthCheck
- If true, enables the lengthCheck Option.public void run()
protected void sendAck(Message<byte[]> message)
protected boolean asyncSendMessage(DatagramPacket packet)
protected DatagramPacket receive() throws Exception
Exception
public void setSocket(DatagramSocket socket)
socket
- the socket to setprotected DatagramSocket getTheSocket()
protected DatagramSocket getSocket()
protected void setSocketAttributes(DatagramSocket socket) throws SocketException
socket
- SocketException
protected void doStop()
MessageProducerSupport
doStop
in class AbstractInternetProtocolReceivingChannelAdapter
public void setSoSendBufferSize(int soSendBufferSize)
public void setLookupHost(boolean lookupHost)
public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
Copyright © 2015. All rights reserved.