org.springframework.integration.ip.udp

Class UnicastSendingMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler

org.springframework.integration.ip.udp.UnicastSendingMessageHandler

All Implemented Interfaces:

Runnable, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, Lifecycle, Ordered, Orderable, CommonSocketOptions, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, MessageHandler

Direct Known Subclasses:

MulticastSendingMessageHandler

public class UnicastSendingMessageHandler
extends AbstractInternetProtocolSendingMessageHandler
implements Runnable

A MessageHandler implementation that maps a Message into a UDP datagram packet and sends that to the specified host and port. Messages can be basic, with no support for reliability, can be prefixed by a length so the receiving end can detect truncation, and can require a UDP acknowledgment to confirm delivery.

Since:

2.0

Author:

Gary Russell

Field Summary

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

logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
UnicastSendingMessageHandler(String host, int port) Basic constructor; no reliability; no acknowledgment.
UnicastSendingMessageHandler(String host, int port, boolean lengthCheck) Can used to add a length to each packet which can be checked at the destination.
UnicastSendingMessageHandler(String host, int port, boolean lengthCheck, boolean acknowledge, String ackHost, int ackPort, int ackTimeout) Add a length and/or acknowledgment request to packets.
UnicastSendingMessageHandler(String host, int port, boolean acknowledge, String ackHost, int ackPort, int ackTimeout) Add an acknowledgment request to packets.

Method Summary

Modifier and Type	Method and Description
void	doStart()
protected void	doStop()
int	getAckPort()
String	getComponentType() Subclasses may implement this method to provide component type information.
protected DatagramSocket	getSocket()
int	getSoReceiveBufferSize()
protected DatagramSocket	getTheSocket()
void	handleMessageInternal(Message<?> message)
boolean	isAcknowledge()
protected void	onInit() Subclasses may implement this for initialization logic.
void	restartAckThread() If exposed as an MBean, can be used to restart the ack thread if a fatal (bind) error occurred, without bouncing the JVM.
void	run() Process acknowledgments, if requested.
protected void	send(DatagramPacket packet)
void	setAckCounter(int ackCounter)
void	setLocalAddress(String localAddress) On a multi-homed system, specifies the ip address of the network interface used to communicate.
protected void	setReliabilityAttributes(boolean lengthCheck, boolean acknowledge, String ackHost, int ackPort, int ackTimeout)
protected void	setSocket(DatagramSocket socket)
protected void	setSocketAttributes(DatagramSocket socket)
void	setSoReceiveBufferSize(int size)
void	setTaskExecutor(Executor taskExecutor)
void	shutDown() Deprecated. Use stop() instead.

Methods inherited from class org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler

getDestinationAddress, getHost, getPort, getSoSendBufferSize, getSoTimeout, isRunning, setSoSendBufferSize, setSoTimeout, start, stop

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

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, 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.support.context.NamedComponent

getComponentName

Constructor Detail

UnicastSendingMessageHandler

public UnicastSendingMessageHandler(String host,
                                    int port)

Basic constructor; no reliability; no acknowledgment.

Parameters:

host - Destination host.

port - Destination port.

UnicastSendingMessageHandler

public UnicastSendingMessageHandler(String host,
                                    int port,
                                    boolean lengthCheck)

Can used to add a length to each packet which can be checked at the destination.

Parameters:

host - Destination Host.

port - Destination Port.

lengthCheck - If true, packets will contain a length.

UnicastSendingMessageHandler

public UnicastSendingMessageHandler(String host,
                                    int port,
                                    boolean acknowledge,
                                    String ackHost,
                                    int ackPort,
                                    int ackTimeout)

Add an acknowledgment request to packets.

Parameters:

host - Destination Host.

port - Destination Port.

acknowledge - If true, packets will request acknowledgment.

ackHost - The host to which acks should be sent. Required if ack true.

ackPort - The port to which acks should be sent.

ackTimeout - How long we will wait (milliseconds) for the ack.

UnicastSendingMessageHandler

public UnicastSendingMessageHandler(String host,
                                    int port,
                                    boolean lengthCheck,
                                    boolean acknowledge,
                                    String ackHost,
                                    int ackPort,
                                    int ackTimeout)

Add a length and/or acknowledgment request to packets.

Parameters:

host - Destination Host.

port - Destination Port.

lengthCheck - If true, packets will contain a length.

acknowledge - If true, packets will request acknowledgment.

ackHost - The host to which acks should be sent. Required if ack true.

ackPort - The port to which acks should be sent.

ackTimeout - How long we will wait (milliseconds) for the ack.

Method Detail

setReliabilityAttributes

protected final void setReliabilityAttributes(boolean lengthCheck,
                                              boolean acknowledge,
                                              String ackHost,
                                              int ackPort,
                                              int ackTimeout)

doStart

public void doStart()

Specified by:

doStart in class AbstractInternetProtocolSendingMessageHandler

doStop

protected void doStop()

Specified by:

doStop in class AbstractInternetProtocolSendingMessageHandler

handleMessageInternal

public void handleMessageInternal(Message<?> message)
                           throws MessageRejectedException,
                                  MessageHandlingException,
                                  MessageDeliveryException

Specified by:

handleMessageInternal in class AbstractMessageHandler

Throws:

MessageRejectedException

MessageHandlingException

MessageDeliveryException

send

protected void send(DatagramPacket packet)
             throws Exception

Throws:

Exception

setSocket

protected void setSocket(DatagramSocket socket)

getTheSocket

protected DatagramSocket getTheSocket()

getSocket

protected DatagramSocket getSocket()
                            throws IOException

Throws:

IOException

setSoReceiveBufferSize

public void setSoReceiveBufferSize(int size)

Specified by:

setSoReceiveBufferSize in interface CommonSocketOptions

Overrides:

setSoReceiveBufferSize in class AbstractInternetProtocolSendingMessageHandler

Parameters:

size - The receive buffer size.

See Also:

Socket.setReceiveBufferSize(int), DatagramSocket.setReceiveBufferSize(int)

setLocalAddress

public void setLocalAddress(String localAddress)

Description copied from interface: CommonSocketOptions

On a multi-homed system, specifies the ip address of the network interface used to communicate. For inbound adapters and gateways, specifies the interface used to listed for incoming connections. If omitted, the endpoint will listen on all available adapters. For the UDP multicast outbound adapter specifies the interface to which multicast packets will be sent. For UDP unicast and multicast adapters, specifies which interface to which the acknowledgment socket will be bound. Does not apply to TCP outbound adapters and gateways.

Specified by:

setLocalAddress in interface CommonSocketOptions

Parameters:

localAddress - The local address.

setTaskExecutor

public void setTaskExecutor(Executor taskExecutor)

setAckCounter

public void setAckCounter(int ackCounter)

Parameters:

ackCounter - the ackCounter to set

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class AbstractMessageHandler

isAcknowledge

public boolean isAcknowledge()

Returns:

the acknowledge

getAckPort

public int getAckPort()

Returns:

the ackPort

getSoReceiveBufferSize

public int getSoReceiveBufferSize()

Returns:

the soReceiveBufferSize

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractMessageHandler

Throws:

Exception - Any exception.

setSocketAttributes

protected void setSocketAttributes(DatagramSocket socket)
                            throws SocketException

Throws:

SocketException

run

public void run()

Process acknowledgments, if requested.

Specified by:

run in interface Runnable

restartAckThread

public void restartAckThread()

If exposed as an MBean, can be used to restart the ack thread if a fatal (bind) error occurred, without bouncing the JVM.

shutDown

@Deprecated
public void shutDown()

Deprecated. Use stop() instead.