public class DefaultSerializableMessage extends java.lang.Object implements SerializableMessage
Constructor and Description |
---|
DefaultSerializableMessage() |
Modifier and Type | Method and Description |
---|---|
void |
addMessageHeader(java.lang.String key,
java.lang.String val) |
java.lang.String |
getContent() |
java.lang.String |
getContentEncoding() |
java.util.Map<java.lang.String,java.lang.String> |
getMessageHeaders()
Returns a view of all the existing headers associated with the message.
|
java.lang.String |
getNextServiceId() |
java.lang.String |
getUniqueId() |
void |
removeMessageHeader(java.lang.String key) |
void |
setContent(java.lang.String payload) |
void |
setContentEncoding(java.lang.String payloadEncoding) |
void |
setMessageHeaders(java.util.Map<java.lang.String,java.lang.String> hdrs)
Set the message headers associated with the message.
|
void |
setNextServiceId(java.lang.String s) |
void |
setUniqueId(java.lang.String uniqueId) |
DefaultSerializableMessage |
withHeadersFromProperties(java.util.Properties props)
Convenience method to do the same as
setMessageHeaders(Map) converting any non-string
keys/values into Strings. |
DefaultSerializableMessage |
withMessageHeaders(java.util.Map<java.lang.String,java.lang.String> hdrs)
Convenience method for method chaining.
|
DefaultSerializableMessage |
withNextServiceId(java.lang.String s)
Convenience method for method chaining.
|
DefaultSerializableMessage |
withPayload(java.lang.String payload)
Convenience method for chaining.
|
DefaultSerializableMessage |
withPayloadEncoding(java.lang.String enc)
Convenience method for method chaining.
|
DefaultSerializableMessage |
withUniqueId(java.lang.String uid)
Convenience method for chaining.
|
public void addMessageHeader(java.lang.String key, java.lang.String val)
addMessageHeader
in interface SerializableMessage
public void removeMessageHeader(java.lang.String key)
removeMessageHeader
in interface SerializableMessage
public java.util.Map<java.lang.String,java.lang.String> getMessageHeaders()
SerializableMessage
Any changes to the returned Map
are not guaranteed to be reflected in underlying map.
You should treat the returned Map as a read only view of the current message headers. Use
SerializableMessage.addMessageHeader(String, String)
or SerializableMessage.removeMessageHeader(String)
to manipulate
individual headers.
getMessageHeaders
in interface SerializableMessage
public void setMessageHeaders(java.util.Map<java.lang.String,java.lang.String> hdrs)
setMessageHeaders
in interface SerializableMessage
hdrs
- the headers, null means to clear all headers.public java.lang.String getUniqueId()
getUniqueId
in interface SerializableMessage
public void setUniqueId(java.lang.String uniqueId)
setUniqueId
in interface SerializableMessage
public java.lang.String getContent()
getContent
in interface SerializableMessage
public void setContent(java.lang.String payload)
setContent
in interface SerializableMessage
public java.lang.String getContentEncoding()
getContentEncoding
in interface SerializableMessage
public void setContentEncoding(java.lang.String payloadEncoding)
setContentEncoding
in interface SerializableMessage
public DefaultSerializableMessage withPayload(java.lang.String payload)
payload
- the payloadsetContent(String)
public DefaultSerializableMessage withUniqueId(java.lang.String uid)
uid
- the uniqueid.setUniqueId(String)
public DefaultSerializableMessage withPayloadEncoding(java.lang.String enc)
enc
- the encodingpublic DefaultSerializableMessage withMessageHeaders(java.util.Map<java.lang.String,java.lang.String> hdrs)
hdrs
- the message headerssetMessageHeaders(Map)
public DefaultSerializableMessage withNextServiceId(java.lang.String s)
s
- the next ServiceId.setNextServiceId(String)
public DefaultSerializableMessage withHeadersFromProperties(java.util.Properties props)
setMessageHeaders(Map)
converting any non-string
keys/values into Strings.props
- the properties that should become message headers; null means to clear all
headers.setMessageHeaders(Map)
public java.lang.String getNextServiceId()
getNextServiceId
in interface SerializableMessage
public void setNextServiceId(java.lang.String s)
setNextServiceId
in interface SerializableMessage