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<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, ExpressionCapable, Orderable, IntegrationPattern, CommonSocketOptions, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>

Direct Known Subclasses:

UnicastSendingMessageHandler

public abstract class AbstractInternetProtocolSendingMessageHandler
extends AbstractMessageHandler
implements CommonSocketOptions, ManageableLifecycle

Base class for UDP MessageHandlers.

Since:

2.0

Author:

Gary Russell, Christian Tzolov

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
AbstractInternetProtocolSendingMessageHandler(String host, int port)

Method Summary

Modifier and Type	Method	Description
protected abstract void	doStart()
protected abstract void	doStop()
SocketAddress	getDestinationAddress()
String	getHost()
int	getPort()
int	getSoSendBufferSize()
int	getSoTimeout()
boolean	isRunning()
void	setSoReceiveBufferSize(int size)
void	setSoSendBufferSize(int size)
void	setSoTimeout(int timeout)
void	start()
void	stop()

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, handleMessageInternal, onComplete, onError, onNext, onSubscribe, setObservationConvention

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.ip.CommonSocketOptions

setLocalAddress

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

getThisAs

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Details

AbstractInternetProtocolSendingMessageHandler

public AbstractInternetProtocolSendingMessageHandler(String host,
 int port)

Method Details

setSoTimeout

public void setSoTimeout(int timeout)

Specified by:

setSoTimeout in interface CommonSocketOptions

Parameters:

timeout - The timeout.

See Also:

• DatagramSocket.setSoTimeout(int)

setSoReceiveBufferSize

public void setSoReceiveBufferSize(int size)

Specified by:

setSoReceiveBufferSize in interface CommonSocketOptions

Parameters:

size - The receive buffer size.

See Also:

• DatagramSocket.setReceiveBufferSize(int)

setSoSendBufferSize

public void setSoSendBufferSize(int size)

Specified by:

setSoSendBufferSize in interface CommonSocketOptions

Parameters:

size - The send buffer size.

See Also:

• DatagramSocket.setSendBufferSize(int)

getHost

public String getHost()

Returns:

the host

getPort

public int getPort()

Returns:

the port

getDestinationAddress

public 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:

start in interface Lifecycle

Specified by:

start in interface ManageableLifecycle

doStart

protected abstract void doStart()

stop

public void stop()

Specified by:

stop in interface Lifecycle

Specified by:

stop in interface ManageableLifecycle

doStop

protected abstract void doStop()

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

Specified by:

isRunning in interface ManageableLifecycle