org.springframework.integration.support

Class MessageBuilder<T>

java.lang.Object

org.springframework.integration.support.AbstractIntegrationMessageBuilder<T>

org.springframework.integration.support.MessageBuilder<T>

public final class MessageBuilder<T>
extends AbstractIntegrationMessageBuilder<T>

The default message builder; creates immutable GenericMessages. Named MessageBuilder instead of DefaultMessageBuilder for backwards compatibility.

Author:

Arjen Poutsma, Mark Fisher, Oleg Zhurakousky, Dave Syer, Gary Russell, Artem Bilan

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.Message<T>	build()
MessageBuilder<T>	copyHeaders(java.util.Map<java.lang.String,?> headersToCopy) Copy the name-value pairs from the provided Map.
MessageBuilder<T>	copyHeadersIfAbsent(java.util.Map<java.lang.String,?> headersToCopy) Copy the name-value pairs from the provided Map.
static <T> MessageBuilder<T>	fromMessage(org.springframework.messaging.Message<T> message) Create a builder for a new Message instance pre-populated with all of the headers copied from the provided message.
protected java.lang.Object	getCorrelationId()
java.util.Map<java.lang.String,java.lang.Object>	getHeaders()
T	getPayload()
protected java.util.List<java.util.List<java.lang.Object>>	getSequenceDetails()
protected java.lang.Object	getSequenceNumber()
protected java.lang.Object	getSequenceSize()
MessageBuilder<T>	popSequenceDetails()
MessageBuilder<T>	pushSequenceDetails(java.lang.Object correlationId, int sequenceNumber, int sequenceSize)
MessageBuilder<T>	readOnlyHeaders(java.lang.String... readOnlyHeaders)
MessageBuilder<T>	removeHeader(java.lang.String headerName) Remove the value for the given header name.
MessageBuilder<T>	removeHeaders(java.lang.String... headerPatterns) Removes all headers provided via array of 'headerPatterns'.
MessageBuilder<T>	setCorrelationId(java.lang.Object correlationId)
MessageBuilder<T>	setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
MessageBuilder<T>	setErrorChannelName(java.lang.String errorChannelName)
MessageBuilder<T>	setExpirationDate(java.util.Date expirationDate)
MessageBuilder<T>	setExpirationDate(java.lang.Long expirationDate)
MessageBuilder<T>	setHeader(java.lang.String headerName, java.lang.Object headerValue) Set the value for the given header name.
MessageBuilder<T>	setHeaderIfAbsent(java.lang.String headerName, java.lang.Object headerValue) Set the value for the given header name only if the header name is not already associated with a value.
MessageBuilder<T>	setPriority(java.lang.Integer priority)
MessageBuilder<T>	setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)
MessageBuilder<T>	setReplyChannelName(java.lang.String replyChannelName)
MessageBuilder<T>	setSequenceNumber(java.lang.Integer sequenceNumber)
MessageBuilder<T>	setSequenceSize(java.lang.Integer sequenceSize)
static <T> MessageBuilder<T>	withPayload(T payload) Create a builder for a new Message instance with the provided payload.

Methods inherited from class java.lang.Object

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

Method Detail

getPayload

public T getPayload()

Specified by:

getPayload in class AbstractIntegrationMessageBuilder<T>

getHeaders

public java.util.Map<java.lang.String,java.lang.Object> getHeaders()

Specified by:

getHeaders in class AbstractIntegrationMessageBuilder<T>

fromMessage

public static <T> MessageBuilder<T> fromMessage(org.springframework.messaging.Message<T> message)

Create a builder for a new Message instance pre-populated with all of the headers copied from the provided message. The payload of the provided Message will also be used as the payload for the new message.

Type Parameters:

T - The type of the payload.

Parameters:

message - the Message from which the payload and all headers will be copied

Returns:

A MessageBuilder.

withPayload

public static <T> MessageBuilder<T> withPayload(T payload)

Create a builder for a new Message instance with the provided payload.

Type Parameters:

T - The type of the payload.

Parameters:

payload - the payload for the new message

Returns:

A MessageBuilder.

setHeader

public MessageBuilder<T> setHeader(java.lang.String headerName,
                                   java.lang.Object headerValue)

Set the value for the given header name. If the provided value is null, the header will be removed.

Specified by:

setHeader in class AbstractIntegrationMessageBuilder<T>

Parameters:

headerName - The header name.

headerValue - The header value.

Returns:

this MessageBuilder.

setHeaderIfAbsent

public MessageBuilder<T> setHeaderIfAbsent(java.lang.String headerName,
                                           java.lang.Object headerValue)

Set the value for the given header name only if the header name is not already associated with a value.

Specified by:

setHeaderIfAbsent in class AbstractIntegrationMessageBuilder<T>

Parameters:

headerName - The header name.

headerValue - The header value.

Returns:

this MessageBuilder.

removeHeaders

public MessageBuilder<T> removeHeaders(java.lang.String... headerPatterns)

Removes all headers provided via array of 'headerPatterns'. As the name suggests the array may contain simple matching patterns for header names. Supported pattern styles are: "xxx*", "*xxx", "*xxx*" and "xxx*yyy".

Specified by:

removeHeaders in class AbstractIntegrationMessageBuilder<T>

Parameters:

headerPatterns - The header patterns.

Returns:

this MessageBuilder.

removeHeader

public MessageBuilder<T> removeHeader(java.lang.String headerName)

Remove the value for the given header name.

Specified by:

removeHeader in class AbstractIntegrationMessageBuilder<T>

Parameters:

headerName - The header name.

Returns:

this MessageBuilder.

copyHeaders

public MessageBuilder<T> copyHeaders(java.util.Map<java.lang.String,?> headersToCopy)

Copy the name-value pairs from the provided Map. This operation will overwrite any existing values. Use { copyHeadersIfAbsent(Map) to avoid overwriting values. Note that the 'id' and 'timestamp' header values will never be overwritten.

Specified by:

copyHeaders in class AbstractIntegrationMessageBuilder<T>

Parameters:

headersToCopy - The headers to copy.

Returns:

this MessageBuilder.

See Also:

MessageHeaders.ID, MessageHeaders.TIMESTAMP

copyHeadersIfAbsent

public MessageBuilder<T> copyHeadersIfAbsent(java.util.Map<java.lang.String,?> headersToCopy)

Copy the name-value pairs from the provided Map. This operation will not overwrite any existing values.

Specified by:

copyHeadersIfAbsent in class AbstractIntegrationMessageBuilder<T>

Parameters:

headersToCopy - The headers to copy.

Returns:

this MessageBuilder.

getSequenceDetails

protected java.util.List<java.util.List<java.lang.Object>> getSequenceDetails()

Specified by:

getSequenceDetails in class AbstractIntegrationMessageBuilder<T>

getCorrelationId

protected java.lang.Object getCorrelationId()

Specified by:

getCorrelationId in class AbstractIntegrationMessageBuilder<T>

getSequenceNumber

protected java.lang.Object getSequenceNumber()

Specified by:

getSequenceNumber in class AbstractIntegrationMessageBuilder<T>

getSequenceSize

protected java.lang.Object getSequenceSize()

Specified by:

getSequenceSize in class AbstractIntegrationMessageBuilder<T>

pushSequenceDetails

public MessageBuilder<T> pushSequenceDetails(java.lang.Object correlationId,
                                             int sequenceNumber,
                                             int sequenceSize)

Overrides:

pushSequenceDetails in class AbstractIntegrationMessageBuilder<T>

popSequenceDetails

public MessageBuilder<T> popSequenceDetails()

Overrides:

popSequenceDetails in class AbstractIntegrationMessageBuilder<T>

setExpirationDate

public MessageBuilder<T> setExpirationDate(java.lang.Long expirationDate)

Overrides:

setExpirationDate in class AbstractIntegrationMessageBuilder<T>

setExpirationDate

public MessageBuilder<T> setExpirationDate(java.util.Date expirationDate)

Overrides:

setExpirationDate in class AbstractIntegrationMessageBuilder<T>

setCorrelationId

public MessageBuilder<T> setCorrelationId(java.lang.Object correlationId)

Overrides:

setCorrelationId in class AbstractIntegrationMessageBuilder<T>

setReplyChannel

public MessageBuilder<T> setReplyChannel(org.springframework.messaging.MessageChannel replyChannel)

Overrides:

setReplyChannel in class AbstractIntegrationMessageBuilder<T>

setReplyChannelName

public MessageBuilder<T> setReplyChannelName(java.lang.String replyChannelName)

Overrides:

setReplyChannelName in class AbstractIntegrationMessageBuilder<T>

setErrorChannel

public MessageBuilder<T> setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)

Overrides:

setErrorChannel in class AbstractIntegrationMessageBuilder<T>

setErrorChannelName

public MessageBuilder<T> setErrorChannelName(java.lang.String errorChannelName)

Overrides:

setErrorChannelName in class AbstractIntegrationMessageBuilder<T>

setSequenceNumber

public MessageBuilder<T> setSequenceNumber(java.lang.Integer sequenceNumber)

Overrides:

setSequenceNumber in class AbstractIntegrationMessageBuilder<T>

setSequenceSize

public MessageBuilder<T> setSequenceSize(java.lang.Integer sequenceSize)

Overrides:

setSequenceSize in class AbstractIntegrationMessageBuilder<T>

setPriority

public MessageBuilder<T> setPriority(java.lang.Integer priority)

Overrides:

setPriority in class AbstractIntegrationMessageBuilder<T>

readOnlyHeaders

public MessageBuilder<T> readOnlyHeaders(java.lang.String... readOnlyHeaders)

build

public org.springframework.messaging.Message<T> build()

Specified by:

build in class AbstractIntegrationMessageBuilder<T>