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 interface |
MessageHeaders.IdGenerator |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONTENT_TYPE |
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
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