Class AbstractInternetProtocolSendingMessageHandler
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler
- All Implemented Interfaces:
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>,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.context.ApplicationContextAware,org.springframework.context.Lifecycle,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.IntegrationPattern,CommonSocketOptions,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.MessageHandler,reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>
- Direct Known Subclasses:
UnicastSendingMessageHandler
public abstract class AbstractInternetProtocolSendingMessageHandler extends org.springframework.integration.handler.AbstractMessageHandler implements CommonSocketOptions, org.springframework.integration.support.management.ManageableLifecycle
Base class for UDP MessageHandlers.
- Since:
- 2.0
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description AbstractInternetProtocolSendingMessageHandler(java.lang.String host, int port) -
Method Summary
Modifier and Type Method Description protected abstract voiddoStart()protected abstract voiddoStop()java.net.SocketAddressgetDestinationAddress()java.lang.StringgetHost()intgetPort()intgetSoSendBufferSize()intgetSoTimeout()booleanisRunning()voidsetSoReceiveBufferSize(int size)voidsetSoSendBufferSize(int size)voidsetSoTimeout(int timeout)voidstart()voidstop()Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
handleMessage, handleMessageInternal, onComplete, onError, onNext, onSubscribeMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods 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, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.ip.CommonSocketOptions
setLocalAddress
-
Constructor Details
-
AbstractInternetProtocolSendingMessageHandler
public AbstractInternetProtocolSendingMessageHandler(java.lang.String host, int port)
-
-
Method Details
-
setSoTimeout
public void setSoTimeout(int timeout)- Specified by:
setSoTimeoutin interfaceCommonSocketOptions- Parameters:
timeout- The timeout.- See Also:
DatagramSocket.setSoTimeout(int)
-
setSoReceiveBufferSize
public void setSoReceiveBufferSize(int size)- Specified by:
setSoReceiveBufferSizein interfaceCommonSocketOptions- Parameters:
size- The receive buffer size.- See Also:
DatagramSocket.setReceiveBufferSize(int)
-
setSoSendBufferSize
public void setSoSendBufferSize(int size)- Specified by:
setSoSendBufferSizein interfaceCommonSocketOptions- Parameters:
size- The send buffer size.- See Also:
DatagramSocket.setSendBufferSize(int)
-
getHost
public java.lang.String getHost()- Returns:
- the host
-
getPort
public int getPort()- Returns:
- the port
-
getDestinationAddress
public java.net.SocketAddress getDestinationAddress()- Returns:
- the destinationAddress
-
getSoTimeout
public int getSoTimeout()- Returns:
- the soTimeout
-
getSoSendBufferSize
public int getSoSendBufferSize()- Returns:
- the soSendBufferSize
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle- Specified by:
startin interfaceorg.springframework.integration.support.management.ManageableLifecycle
-
doStart
protected abstract void doStart() -
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle- Specified by:
stopin interfaceorg.springframework.integration.support.management.ManageableLifecycle
-
doStop
protected abstract void doStop() -
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle- Specified by:
isRunningin interfaceorg.springframework.integration.support.management.ManageableLifecycle
-