org.springframework.integration.ip.tcp.connection

Class TcpMessageMapper

java.lang.Object

org.springframework.integration.ip.tcp.connection.TcpMessageMapper

All Implemented Interfaces:

Aware, BeanFactoryAware, InboundMessageMapper<TcpConnection>, OutboundMessageMapper<Object>

Direct Known Subclasses:

MessageConvertingTcpMessageMapper

public class TcpMessageMapper
extends Object
implements InboundMessageMapper<TcpConnection>, OutboundMessageMapper<Object>, BeanFactoryAware

Maps incoming data from a TcpConnection to a Message. If StringToBytes is true (default), payloads of type String are converted to a byte[] using the supplied charset (UTF-8 by default). Inbound messages include headers representing the remote end of the connection as well as a connection id that can be used by a TcpSender to correlate which connection to send a reply. If applySequence is set, adds standard correlationId/sequenceNumber headers allowing for downstream (unbounded) resequencing. *

Since:

2.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TcpMessageMapper()

Method Summary

Modifier and Type	Method and Description
protected void	addCustomHeaders(TcpConnection connection, AbstractIntegrationMessageBuilder<?> messageBuilder)
protected void	addStandardHeaders(TcpConnection connection, AbstractIntegrationMessageBuilder<?> messageBuilder)
Object	fromMessage(Message<?> message)
protected MessageBuilderFactory	getMessageBuilderFactory()
void	setAddContentTypeHeader(boolean addContentTypeHeader) Set to true to add a content type header; default false.
void	setApplySequence(boolean applySequence)
void	setBeanFactory(BeanFactory beanFactory)
void	setCharset(String charset) Set the charset to use when converting outbound String messages to byte[].
void	setContentType(String contentType) Set the content type header value to add to inbound messages when addContentTypeHeader is true.
void	setStringToBytes(boolean stringToBytes) Sets whether outbound String payloads are to be converted to byte[].
protected Map<String,?>	supplyCustomHeaders(TcpConnection connection) Override to provide additional headers.
Message<?>	toMessage(TcpConnection connection)

Methods inherited from class java.lang.Object

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

Field Detail

logger

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

Constructor Detail

TcpMessageMapper

public TcpMessageMapper()

Method Detail

setCharset

public void setCharset(String charset)

Set the charset to use when converting outbound String messages to byte[].

Parameters:

charset - the charset to set

setStringToBytes

public void setStringToBytes(boolean stringToBytes)

Sets whether outbound String payloads are to be converted to byte[]. Default is true.

Parameters:

stringToBytes - The stringToBytes to set.

setApplySequence

public void setApplySequence(boolean applySequence)

Parameters:

applySequence - The applySequence to set.

setContentType

public void setContentType(String contentType)

Set the content type header value to add to inbound messages when addContentTypeHeader is true. Default application/octet-stream;charset=UTF-8. This default is not modified by setCharset(String).

Parameters:

contentType - the content type header value to set.

Since:

4.3

See Also:

setAddContentTypeHeader(boolean), setCharset(String)

setAddContentTypeHeader

public void setAddContentTypeHeader(boolean addContentTypeHeader)

Set to true to add a content type header; default false.

Parameters:

addContentTypeHeader - true to add a content type header.

Since:

4.3

See Also:

setContentType(String)

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getMessageBuilderFactory

protected MessageBuilderFactory getMessageBuilderFactory()

toMessage

public Message<?> toMessage(TcpConnection connection)
                     throws Exception

Specified by:

toMessage in interface InboundMessageMapper<TcpConnection>

Throws:

Exception

addStandardHeaders

protected final void addStandardHeaders(TcpConnection connection,
                                        AbstractIntegrationMessageBuilder<?> messageBuilder)

addCustomHeaders

protected final void addCustomHeaders(TcpConnection connection,
                                      AbstractIntegrationMessageBuilder<?> messageBuilder)

supplyCustomHeaders

protected Map<String,?> supplyCustomHeaders(TcpConnection connection)

Override to provide additional headers. The standard headers cannot be overridden and any such headers will be ignored if provided in the result.

Parameters:

connection - the connection.

Returns:

A Map of <String, ?> headers to be added to the message.

fromMessage

public Object fromMessage(Message<?> message)
                   throws Exception

Specified by:

fromMessage in interface OutboundMessageMapper<Object>

Throws:

Exception