public final class MessageHeaders
extends java.lang.Object
implements java.util.Map<java.lang.String,java.lang.Object>, java.io.Serializable
Message
IMPORTANT: This class is immutable. Any mutating operation
(e.g., put(..), putAll(..) etc.) will throw UnsupportedOperationException
.
To create MessageHeaders instance use fluent
MessageBuilder
API
MessageBuilder.withPayload("foo").setHeader("key1", "value1").setHeader("key2", "value2");or create an instance of GenericMessage passing payload as
Object
and headers as a regular Map
Map headers = new HashMap(); headers.put("key1", "value1"); headers.put("key2", "value2"); new GenericMessage("foo", headers);
MessageBuilder
,
Serialized FormModifier and Type | Class and Description |
---|---|
static class |
MessageHeaders.AlternativeJdkIdGenerator
A variation of
UUID.randomUUID() that uses SecureRandom only for
the initial seed and Random thereafter, which provides better performance
in exchange for less securely random id's. |
static interface |
MessageHeaders.IdGenerator |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONTENT_TYPE |
private static MessageHeaders.IdGenerator |
defaultIdGenerator |
static java.lang.String |
ERROR_CHANNEL |
static java.util.List<java.lang.String> |
HEADER_NAMES |
private java.util.Map<java.lang.String,java.lang.Object> |
headers |
static java.lang.String |
ID
The key for the Message ID.
|
private static MessageHeaders.IdGenerator |
idGenerator |
private static Log |
logger |
static java.lang.String |
REPLY_CHANNEL |
private static long |
serialVersionUID |
static java.lang.String |
TIMESTAMP |
Constructor and Description |
---|
MessageHeaders(java.util.Map<java.lang.String,java.lang.Object> headers) |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Since MessageHeaders are immutable the call to this method will result in
UnsupportedOperationException |
boolean |
containsKey(java.lang.Object key) |
boolean |
containsValue(java.lang.Object value) |
java.util.Set<java.util.Map.Entry<java.lang.String,java.lang.Object>> |
entrySet() |
boolean |
equals(java.lang.Object object) |
java.lang.Object |
get(java.lang.Object key) |
<T> T |
get(java.lang.Object key,
java.lang.Class<T> type) |
java.lang.Object |
getErrorChannel() |
java.util.UUID |
getId() |
java.lang.Object |
getReplyChannel() |
java.lang.Long |
getTimestamp() |
int |
hashCode() |
boolean |
isEmpty() |
java.util.Set<java.lang.String> |
keySet() |
java.lang.Object |
put(java.lang.String key,
java.lang.Object value)
Since MessageHeaders are immutable the call to this method will result in
UnsupportedOperationException |
void |
putAll(java.util.Map<? extends java.lang.String,? extends java.lang.Object> t)
Since MessageHeaders are immutable the call to this method will result in
UnsupportedOperationException |
private void |
readObject(java.io.ObjectInputStream in) |
java.lang.Object |
remove(java.lang.Object key)
Since MessageHeaders are immutable the call to this method will result in
UnsupportedOperationException |
int |
size() |
java.lang.String |
toString() |
java.util.Collection<java.lang.Object> |
values() |
private void |
writeObject(java.io.ObjectOutputStream out) |
private static final long serialVersionUID
private static final Log logger
private static volatile MessageHeaders.IdGenerator idGenerator
private static volatile MessageHeaders.IdGenerator defaultIdGenerator
public static final java.lang.String ID
public static final java.lang.String TIMESTAMP
public static final java.lang.String REPLY_CHANNEL
public static final java.lang.String ERROR_CHANNEL
public static final java.lang.String CONTENT_TYPE
public static final java.util.List<java.lang.String> HEADER_NAMES
private final java.util.Map<java.lang.String,java.lang.Object> headers
public MessageHeaders(java.util.Map<java.lang.String,java.lang.Object> headers)
public java.util.UUID getId()
public java.lang.Long getTimestamp()
public java.lang.Object getReplyChannel()
public java.lang.Object getErrorChannel()
public <T> T get(java.lang.Object key, java.lang.Class<T> type)
public int hashCode()
hashCode
in interface java.util.Map<java.lang.String,java.lang.Object>
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object object)
equals
in interface java.util.Map<java.lang.String,java.lang.Object>
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public boolean containsKey(java.lang.Object key)
containsKey
in interface java.util.Map<java.lang.String,java.lang.Object>
public boolean containsValue(java.lang.Object value)
containsValue
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.util.Set<java.util.Map.Entry<java.lang.String,java.lang.Object>> entrySet()
entrySet
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.lang.Object get(java.lang.Object key)
get
in interface java.util.Map<java.lang.String,java.lang.Object>
public boolean isEmpty()
isEmpty
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.util.Set<java.lang.String> keySet()
keySet
in interface java.util.Map<java.lang.String,java.lang.Object>
public int size()
size
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.util.Collection<java.lang.Object> values()
values
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.lang.Object put(java.lang.String key, java.lang.Object value)
UnsupportedOperationException
put
in interface java.util.Map<java.lang.String,java.lang.Object>
public void putAll(java.util.Map<? extends java.lang.String,? extends java.lang.Object> t)
UnsupportedOperationException
putAll
in interface java.util.Map<java.lang.String,java.lang.Object>
public java.lang.Object remove(java.lang.Object key)
UnsupportedOperationException
remove
in interface java.util.Map<java.lang.String,java.lang.Object>
public void clear()
UnsupportedOperationException
clear
in interface java.util.Map<java.lang.String,java.lang.Object>
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
java.io.IOException
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException