org.springframework.integration.ip.tcp.connection

Class TcpConnectionSupport

java.lang.Object

org.springframework.integration.ip.tcp.connection.TcpConnectionSupport

All Implemented Interfaces:

Runnable, TcpConnection

Direct Known Subclasses:

TcpConnectionInterceptorSupport, TcpNetConnection, TcpNioConnection

public abstract class TcpConnectionSupport
extends Object
implements TcpConnection

Base class for TcpConnections. TcpConnections are established by client connection factories (outgoing) or server connection factories (incoming).

Since:

2.0

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
TcpConnectionSupport()
TcpConnectionSupport(ApplicationEventPublisher applicationEventPublisher)
TcpConnectionSupport(Socket socket, boolean server, boolean lookupHost, ApplicationEventPublisher applicationEventPublisher, String connectionFactoryName) Creates a TcpConnectionSupport object and publishes a TcpConnectionOpenEvent, if an event publisher is provided.

Method Summary

Methods

Modifier and Type	Method and Description
void	afterSend(Message<?> message)
void	close() Closes this connection.
protected void	closeConnection(boolean isException) If we have been intercepted, propagate the close from the outermost interceptor; otherwise, just call close().
String	getConnectionId()
Deserializer<?>	getDeserializer()
String	getHostAddress()
String	getHostName()
TcpListener	getListener()
TcpMessageMapper	getMapper()
TcpSender	getSender()
Serializer<?>	getSerializer()
long	incrementAndGetConnectionSequence()
protected boolean	isNoReadErrorOnClose()
boolean	isServer()
boolean	isSingleUse()
protected void	publishConnectionCloseEvent()
protected void	publishConnectionExceptionEvent(Throwable t)
protected void	publishConnectionOpenEvent()
void	publishEvent(TcpConnectionEvent event) Allow interceptors etc to publish events, perhaps subclasses of TcpConnectionEvent.
void	registerListener(TcpListener listener) Sets the listener that will receive incoming Messages.
void	registerSender(TcpSender sender) Registers a sender.
protected void	sendExceptionToListener(Exception e)
void	setDeserializer(Deserializer<?> deserializer)
void	setMapper(TcpMessageMapper mapper)
protected void	setNoReadErrorOnClose(boolean noReadErrorOnClose)
void	setSerializer(Serializer<?> serializer)
void	setSingleUse(boolean singleUse)

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.ip.tcp.connection.TcpConnection

getDeserializerStateKey, getPayload, getPort, isOpen, send

Methods inherited from interface java.lang.Runnable

run

Field Detail

logger

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

Constructor Detail

TcpConnectionSupport

public TcpConnectionSupport()

TcpConnectionSupport

public TcpConnectionSupport(ApplicationEventPublisher applicationEventPublisher)

TcpConnectionSupport

public TcpConnectionSupport(Socket socket,
                    boolean server,
                    boolean lookupHost,
                    ApplicationEventPublisher applicationEventPublisher,
                    String connectionFactoryName)

Creates a TcpConnectionSupport object and publishes a TcpConnectionOpenEvent, if an event publisher is provided.

Parameters:

socket - the underlying socket.

server - true if this connection is a server connection

lookupHost - true if reverse lookup of the host name should be performed, otherwise, the ip address will be used for identification purposes.

applicationEventPublisher - the publisher to which open, close and exception events will be sent; may be null if event publishing is not required.

connectionFactoryName - the name of the connection factory creating this connection; used during event publishing, may be null, in which case "unknown" will be used.

Method Detail

afterSend

public void afterSend(Message<?> message)
               throws Exception

Throws:

Exception

close

public void close()

Closes this connection.

Specified by:

close in interface TcpConnection

closeConnection

protected void closeConnection(boolean isException)

If we have been intercepted, propagate the close from the outermost interceptor; otherwise, just call close().

Parameters:

isException - true when this call is the result of an Exception.

getMapper

public TcpMessageMapper getMapper()

Returns:

the mapper

setMapper

public void setMapper(TcpMessageMapper mapper)

Parameters:

mapper - the mapper to set

getDeserializer

public Deserializer<?> getDeserializer()

Specified by:

getDeserializer in interface TcpConnection

Returns:

the deserializer

setDeserializer

public void setDeserializer(Deserializer<?> deserializer)

Parameters:

deserializer - the deserializer to set

getSerializer

public Serializer<?> getSerializer()

Specified by:

getSerializer in interface TcpConnection

Returns:

the serializer

setSerializer

public void setSerializer(Serializer<?> serializer)

Parameters:

serializer - the serializer to set

registerListener

public void registerListener(TcpListener listener)

Sets the listener that will receive incoming Messages.

Parameters:

listener - The listener.

registerSender

public void registerSender(TcpSender sender)

Registers a sender. Used on server side connections so a sender can determine which connection to send a reply to.

Parameters:

sender - the sender.

getListener

public TcpListener getListener()

Specified by:

getListener in interface TcpConnection

Returns:

the listener

getSender

public TcpSender getSender()

Returns:

the sender

setSingleUse

public void setSingleUse(boolean singleUse)

Parameters:

singleUse - true if this socket is to used once and discarded.

isSingleUse

public boolean isSingleUse()

Specified by:

isSingleUse in interface TcpConnection

Returns:

True if connection is used once.

isServer

public boolean isServer()

Specified by:

isServer in interface TcpConnection

Returns:

True if connection is used once.

incrementAndGetConnectionSequence

public long incrementAndGetConnectionSequence()

Specified by:

incrementAndGetConnectionSequence in interface TcpConnection

Returns:

the next sequence number for a message received on this socket

getHostAddress

public String getHostAddress()

Specified by:

getHostAddress in interface TcpConnection

Returns:

the host address

getHostName

public String getHostName()

Specified by:

getHostName in interface TcpConnection

Returns:

the host name

getConnectionId

public String getConnectionId()

Specified by:

getConnectionId in interface TcpConnection

Returns:

a string uniquely representing a connection.

isNoReadErrorOnClose

protected boolean isNoReadErrorOnClose()

setNoReadErrorOnClose

protected void setNoReadErrorOnClose(boolean noReadErrorOnClose)

sendExceptionToListener

protected final void sendExceptionToListener(Exception e)

publishConnectionOpenEvent

protected void publishConnectionOpenEvent()

publishConnectionCloseEvent

protected void publishConnectionCloseEvent()

publishConnectionExceptionEvent

protected void publishConnectionExceptionEvent(Throwable t)

publishEvent

public void publishEvent(TcpConnectionEvent event)

Allow interceptors etc to publish events, perhaps subclasses of TcpConnectionEvent. The event source must be this connection.

Parameters:

event - the event to publish.