org.springframework.messaging.support

Class MessageBuilder<T>

java.lang.Object

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

public final class MessageBuilder<T>
extends java.lang.Object

A builder for creating GenericMessage or ErrorMessage if the payload is Throwable.

Since:

4.0

Author:

Arjen Poutsma, Mark Fisher

See Also:

GenericMessage, ErrorMessage

Field Summary

Fields

Modifier and Type	Field and Description
private MessageHeaderAccessor	headerAccessor
private Message<T>	originalMessage
private T	payload

Constructor Summary

Constructors

Modifier	Constructor and Description
private	MessageBuilder(T payload, Message<T> originalMessage, MessageHeaderAccessor headerAccessor) Private constructor to be invoked from the static factory methods only.

Method Summary

Modifier and Type	Method and Description
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(Message<T> message) Create a builder for a new Message instance pre-populated with all of the headers copied from the provided message.
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>	setErrorChannel(MessageChannel errorChannel)
MessageBuilder<T>	setErrorChannelName(java.lang.String errorChannelName)
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>	setReplyChannel(MessageChannel replyChannel)
MessageBuilder<T>	setReplyChannelName(java.lang.String replyChannelName)
static <T> MessageBuilder<T>	withPayload(T payload) Create a builder for a new Message instance with the provided payload.
static <T> MessageBuilder<T>	withPayloadAndHeaders(T payload, MessageHeaderAccessor headerAccessor) Create a builder for a new Message instance with the provided payload and headers.

Methods inherited from class java.lang.Object

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

Field Detail

payload

private final T payload

headerAccessor

private final MessageHeaderAccessor headerAccessor

originalMessage

private final Message<T> originalMessage

Constructor Detail

MessageBuilder

private MessageBuilder(T payload,
              Message<T> originalMessage,
              MessageHeaderAccessor headerAccessor)

Private constructor to be invoked from the static factory methods only.

Method Detail

fromMessage

public static <T> MessageBuilder<T> fromMessage(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.

Parameters:

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

withPayload

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

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

Parameters:

payload - the payload for the new message

withPayloadAndHeaders

public static <T> MessageBuilder<T> withPayloadAndHeaders(T payload,
                                          MessageHeaderAccessor headerAccessor)

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

Parameters:

payload - the payload for the new message

headerAccessor - the headers for the message

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.

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.

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".

removeHeader

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

Remove the value for the given header name.

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.

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.

setReplyChannel

public MessageBuilder<T> setReplyChannel(MessageChannel replyChannel)

setReplyChannelName

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

setErrorChannel

public MessageBuilder<T> setErrorChannel(MessageChannel errorChannel)

setErrorChannelName

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

build

public Message<T> build()