org.springframework.integration.ip
Class AbstractInternetProtocolSendingMessageHandler

java.lang.Object
  org.springframework.integration.ip.AbstractInternetProtocolSendingMessageHandler

All Implemented Interfaces:

CommonSocketOptions, MessageHandler

Direct Known Subclasses:

AbstractTcpSendingMessageHandler, UnicastSendingMessageHandler

public abstract class AbstractInternetProtocolSendingMessageHandler
extends java.lang.Object
implements MessageHandler, CommonSocketOptions

Base class for all TCP/UDP MessageHandlers.

Since:

2.0

Author:

Gary Russell

Field Summary

protected java.net.SocketAddress	destinationAddress
protected java.util.concurrent.ExecutorService	executorService
protected java.lang.String	host
protected org.apache.commons.logging.Log	logger
protected int	port
protected int	soSendBufferSize
protected int	soTimeout

Constructor Summary

AbstractInternetProtocolSendingMessageHandler(java.lang.String host, int port)

Method Summary

int	getPort()
void	setSoReceiveBufferSize(int size)
void	setSoSendBufferSize(int size)
void	setSoTimeout(int timeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.message.MessageHandler

handleMessage

Field Detail

logger

protected final org.apache.commons.logging.Log logger

destinationAddress

protected final java.net.SocketAddress destinationAddress

host

protected final java.lang.String host

port

protected final int port

soSendBufferSize

protected volatile int soSendBufferSize

soTimeout

protected volatile int soTimeout

executorService

protected volatile java.util.concurrent.ExecutorService executorService

Constructor Detail

AbstractInternetProtocolSendingMessageHandler

public AbstractInternetProtocolSendingMessageHandler(java.lang.String host,
                                                     int port)

Method Detail

setSoTimeout

public void setSoTimeout(int timeout)

Specified by:

setSoTimeout in interface CommonSocketOptions

Parameters:

timeout -

See Also:

Socket#setSoTimeout(int)} and {@link DatagramSocket#setSoTimeout(int)}

setSoReceiveBufferSize

public void setSoReceiveBufferSize(int size)

Specified by:

setSoReceiveBufferSize in interface CommonSocketOptions

Parameters:

size -

See Also:

Socket#setReceiveBufferSize(int)} and {@link DatagramSocket#setReceiveBufferSize(int)}

setSoSendBufferSize

public void setSoSendBufferSize(int size)

Specified by:

setSoSendBufferSize in interface CommonSocketOptions

Parameters:

size -

See Also:

Socket#setSendBufferSize(int)} and {@link DatagramSocket#setSendBufferSize(int)}

getPort

public int getPort()

Returns:

the port