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,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.ApplicationEventPublisherAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.core.MessageProducer,org.springframework.integration.IntegrationPattern,CommonSocketOptions,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent,org.springframework.scheduling.SchedulingAwareRunnable
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
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock -
Constructor Summary
Constructors Constructor Description 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
Modifier and Type Method Description java.net.DatagramSocketgetSocket()Methods inherited from class org.springframework.integration.ip.udp.UnicastReceivingChannelAdapter
asyncSendMessage, doSend, doStop, getComponentType, getPort, getTheSocket, isLongLived, onInit, receive, run, sendAck, setLengthCheck, setLookupHost, setSocket, setSocketAttributes, setSocketCustomizer, setSoSendBufferSizeMethods inherited from class org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter
checkTaskExecutor, doStart, getApplicationEventPublisher, getLocalAddress, getReceiveBufferSize, getSoReceiveBufferSize, getSoTimeout, getTaskExecutor, isListening, setApplicationEventPublisher, setListening, setLocalAddress, setPoolSize, setReceiveBufferSize, setSoReceiveBufferSize, setSoTimeout, setTaskExecutorMethods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
-
Constructor Details
-
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.
-
-
Method Details
-
getSocket
public java.net.DatagramSocket getSocket()- Overrides:
getSocketin classUnicastReceivingChannelAdapter
-