org.springframework.integration.ip.udp
Class MulticastReceivingChannelAdapter
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter
org.springframework.integration.ip.udp.UnicastReceivingChannelAdapter
org.springframework.integration.ip.udp.MulticastReceivingChannelAdapter
- All Implemented Interfaces:
- java.lang.Runnable, BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent, MessageProducer, TrackableComponent, CommonSocketOptions
public class MulticastReceivingChannelAdapter
- extends UnicastReceivingChannelAdapter
Channel adapter that joins a multicast group and receives incoming packets and
sends them to an output channel.
- Since:
- 2.0
Field Summary |
protected java.lang.String |
group
|
Constructor Summary |
MulticastReceivingChannelAdapter(java.lang.String group,
int port)
Constructs a MulticastReceivingChannelAdapter that listens for packets on the
specified multichannel address (group) and port. |
MulticastReceivingChannelAdapter(java.lang.String group,
int port,
boolean lengthCheck)
Constructs a MulticastReceivingChannelAdapter that listens for packets on the
specified multichannel address (group) and port. |
Method Summary |
protected java.net.DatagramSocket |
getSocket()
|
Methods inherited from class org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter |
checkTaskExecutor, doStart, getLocalAddress, getPort, isListening, setLocalAddress, setPoolSize, setReceiveBufferSize, setSoReceiveBufferSize, setSoTimeout, setTaskExecutor |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
group
protected java.lang.String group
MulticastReceivingChannelAdapter
public MulticastReceivingChannelAdapter(java.lang.String group,
int port)
- Constructs a MulticastReceivingChannelAdapter that listens for packets on the
specified multichannel address (group) and port.
- Parameters:
group
- The multichannel address.port
- The port.
MulticastReceivingChannelAdapter
public MulticastReceivingChannelAdapter(java.lang.String group,
int port,
boolean lengthCheck)
- Constructs a MulticastReceivingChannelAdapter that listens for packets on the
specified multichannel address (group) and port. Enables setting the lengthCheck
option, which expects a length to precede the incoming packets.
- Parameters:
group
- The multichannel address.port
- The port.lengthCheck
- If true, enables the lengthCheck Option.
getSocket
protected java.net.DatagramSocket getSocket()
- Overrides:
getSocket
in class UnicastReceivingChannelAdapter