public class MessageHeaderAccessor extends Object
The method getMessageHeaders()
provides access to the underlying,
fully-prepared MessageHeaders
that can then be used as-is (i.e.
without copying) to create a single message as follows:
MessageHeaderAccessor accessor = new MessageHeaderAccessor(); accessor.setHeader("foo", "bar"); Message message = MessageBuilder.createMessage("payload", accessor.getMessageHeaders());
After the above, by default the MessageHeaderAccessor
becomes
immutable. However it is possible to leave it mutable for further initialization
in the same thread, for example:
MessageHeaderAccessor accessor = new MessageHeaderAccessor(); accessor.setHeader("foo", "bar"); accessor.setLeaveMutable(true); Message message = MessageBuilder.createMessage("payload", accessor.getMessageHeaders()); // later on in the same thread... MessageHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message); accessor.setHeader("bar", "baz"); accessor.setImmutable();
The method toMap()
returns a copy of the underlying headers. It can
be used to prepare multiple messages from the same MessageHeaderAccessor
instance:
MessageHeaderAccessor accessor = new MessageHeaderAccessor(); MessageBuilder builder = MessageBuilder.withPayload("payload").setHeaders(accessor); accessor.setHeader("foo", "bar1"); Message message1 = builder.build(); accessor.setHeader("foo", "bar2"); Message message2 = builder.build(); accessor.setHeader("foo", "bar3"); Message message3 = builder.build();
However note that with the above style, the header accessor is shared and
cannot be re-obtained later on. Alternatively it is also possible to create
one MessageHeaderAccessor
per message:
MessageHeaderAccessor accessor1 = new MessageHeaderAccessor(); accessor.set("foo", "bar1"); Message message1 = MessageBuilder.createMessage("payload", accessor1.getMessageHeaders()); MessageHeaderAccessor accessor2 = new MessageHeaderAccessor(); accessor.set("foo", "bar2"); Message message2 = MessageBuilder.createMessage("payload", accessor2.getMessageHeaders()); MessageHeaderAccessor accessor3 = new MessageHeaderAccessor(); accessor.set("foo", "bar3"); Message message3 = MessageBuilder.createMessage("payload", accessor3.getMessageHeaders());
Note that the above examples aim to demonstrate the general idea of using header accessors. The most likely usage however is through subclasses.
Modifier and Type | Field and Description |
---|---|
static Charset |
DEFAULT_CHARSET |
Constructor and Description |
---|
MessageHeaderAccessor()
A constructor to create new headers.
|
MessageHeaderAccessor(Message<?> message)
A constructor accepting the headers of an existing message to copy.
|
Modifier and Type | Method and Description |
---|---|
void |
copyHeaders(Map<String,?> headersToCopy)
Copy the name-value pairs from the provided Map.
|
void |
copyHeadersIfAbsent(Map<String,?> headersToCopy)
Copy the name-value pairs from the provided Map.
|
protected MessageHeaderAccessor |
createAccessor(Message<?> message)
Build a 'nested' accessor for the given message.
|
static <T extends MessageHeaderAccessor> |
getAccessor(Message<?> message,
Class<T> requiredType)
Return the original
MessageHeaderAccessor used to create the headers
of the given Message , or null if that's not available or if
its type does not match the required type. |
static <T extends MessageHeaderAccessor> |
getAccessor(MessageHeaders messageHeaders,
Class<T> requiredType)
A variation of
getAccessor(org.springframework.messaging.Message, Class)
with a MessageHeaders instance instead of a Message . |
MimeType |
getContentType() |
String |
getDetailedLogMessage(Object payload)
Return a more detailed message for logging purposes.
|
protected String |
getDetailedPayloadLogMessage(Object payload) |
Object |
getErrorChannel() |
Object |
getHeader(String headerName)
Retrieve the value for the header with the given name.
|
UUID |
getId() |
MessageHeaders |
getMessageHeaders()
Return the underlying
MessageHeaders instance. |
static MessageHeaderAccessor |
getMutableAccessor(Message<?> message)
Return a mutable
MessageHeaderAccessor for the given message attempting
to match the type of accessor used to create the message headers, or otherwise
wrapping the message with a MessageHeaderAccessor instance. |
Object |
getReplyChannel() |
String |
getShortLogMessage(Object payload)
Return a concise message for logging purposes.
|
protected String |
getShortPayloadLogMessage(Object payload) |
Long |
getTimestamp() |
boolean |
isModified()
Check whether the underlying message headers have been marked as modified.
|
boolean |
isMutable()
Whether the underlying headers can still be modified.
|
protected boolean |
isReadableContentType() |
protected boolean |
isReadOnly(String headerName) |
void |
removeHeader(String headerName)
Remove the value for the given header name.
|
void |
removeHeaders(String... headerPatterns)
Removes all headers provided via array of 'headerPatterns'.
|
void |
setContentType(MimeType contentType) |
void |
setErrorChannel(MessageChannel errorChannel) |
void |
setErrorChannelName(String errorChannelName) |
void |
setHeader(String name,
Object value)
Set the value for the given header name.
|
void |
setHeaderIfAbsent(String name,
Object value)
Set the value for the given header name only if the header name is not
already associated with a value.
|
void |
setImmutable()
By default when
getMessageHeaders() is called, "this"
MessageHeaderAccessor instance can no longer be used to modify the
underlying message headers. |
void |
setLeaveMutable(boolean leaveMutable)
By default when
getMessageHeaders() is called, "this"
MessageHeaderAccessor instance can no longer be used to modify the
underlying message headers and the returned MessageHeaders is immutable. |
protected void |
setModified(boolean modified)
Mark the underlying message headers as modified.
|
void |
setReplyChannel(MessageChannel replyChannel) |
void |
setReplyChannelName(String replyChannelName) |
Map<String,Object> |
toMap()
Return a copy of the underlying header values as a plain
Map object. |
MessageHeaders |
toMessageHeaders()
Return a copy of the underlying header values as a
MessageHeaders object. |
String |
toString() |
protected void |
verifyType(String headerName,
Object headerValue) |
public static final Charset DEFAULT_CHARSET
public MessageHeaderAccessor()
public MessageHeaderAccessor(Message<?> message)
protected MessageHeaderAccessor createAccessor(Message<?> message)
message
- the message to build a new accessor forpublic void setLeaveMutable(boolean leaveMutable)
getMessageHeaders()
is called, "this"
MessageHeaderAccessor
instance can no longer be used to modify the
underlying message headers and the returned MessageHeaders
is immutable.
However when this is set to true
, the returned (underlying)
MessageHeaders
instance remains mutable. To make further modifications
continue to use the same accessor instance or re-obtain it via:
MessageHeaderAccessor.getAccessor(Message, Class)
When modifications are complete use setImmutable()
to prevent
further changes. The intended use case for this mechanism is initialization
of a Message within a single thread.
By default this is set to false
.
public void setImmutable()
getMessageHeaders()
is called, "this"
MessageHeaderAccessor
instance can no longer be used to modify the
underlying message headers. However if setLeaveMutable(boolean)
is used, this method is necessary to indicate explicitly when the
MessageHeaders
instance should no longer be modified.public boolean isMutable()
protected void setModified(boolean modified)
modified
- typically true
, or false
to reset the flagpublic boolean isModified()
true
if the flag has been set, false
otherwisepublic MessageHeaders getMessageHeaders()
MessageHeaders
instance.
Unless setLeaveMutable(boolean)
was set to true
, after
this call, the headers are immutable and this accessor can no longer
modify them.
This method always returns the same MessageHeaders
instance if
invoked multiples times. To obtain a copy of the underlying headers, use
toMessageHeaders()
or toMap()
instead.
public MessageHeaders toMessageHeaders()
MessageHeaders
object.
This method can be invoked many times, with modifications in between where each new call returns a fresh copy of the current header values.
public Map<String,Object> toMap()
Map
object.
This method can be invoked many times, with modifications in between where each new call returns a fresh copy of the current header values.
public Object getHeader(String headerName)
headerName
- the name of the headernull
if none foundpublic void setHeader(String name, Object value)
If the provided value is null
, the header will be removed.
public void setHeaderIfAbsent(String name, Object value)
public void removeHeader(String headerName)
public void removeHeaders(String... headerPatterns)
As the name suggests, array may contain simple matching patterns for header names. Supported pattern styles are: "xxx*", "*xxx", "*xxx*" and "xxx*yyy".
public void copyHeaders(Map<String,?> headersToCopy)
This operation will overwrite any existing values. Use
copyHeadersIfAbsent(Map)
to avoid overwriting values.
public void copyHeadersIfAbsent(Map<String,?> headersToCopy)
This operation will not overwrite any existing values.
protected boolean isReadOnly(String headerName)
public UUID getId()
public Long getTimestamp()
public void setContentType(MimeType contentType)
public MimeType getContentType()
public void setReplyChannelName(String replyChannelName)
public void setReplyChannel(MessageChannel replyChannel)
public Object getReplyChannel()
public void setErrorChannelName(String errorChannelName)
public void setErrorChannel(MessageChannel errorChannel)
public Object getErrorChannel()
public String getShortLogMessage(Object payload)
payload
- the payload that corresponds to the headers.public String getDetailedLogMessage(Object payload)
payload
- the payload that corresponds to the headers.protected boolean isReadableContentType()
public static <T extends MessageHeaderAccessor> T getAccessor(Message<?> message, Class<T> requiredType)
MessageHeaderAccessor
used to create the headers
of the given Message
, or null
if that's not available or if
its type does not match the required type.
This is for cases where the existence of an accessor is strongly expected (followed up with an assertion) or where an accessor will be created otherwise.
null
if nonepublic static <T extends MessageHeaderAccessor> T getAccessor(MessageHeaders messageHeaders, Class<T> requiredType)
getAccessor(org.springframework.messaging.Message, Class)
with a MessageHeaders
instance instead of a Message
.
This is for cases when a full message may not have been created yet.
null
if nonepublic static MessageHeaderAccessor getMutableAccessor(Message<?> message)
MessageHeaderAccessor
for the given message attempting
to match the type of accessor used to create the message headers, or otherwise
wrapping the message with a MessageHeaderAccessor
instance.
This is for cases where a header needs to be updated in generic code while preserving the accessor type for downstream processing.
null
)