public class AsyncMessage extends AbstractMessage
AsyncMessage
- base class for all asynchronous messages.Modifier and Type | Field and Description |
---|---|
java.lang.String |
correlationId
Provides access to the correlation id of the message.
|
static java.lang.String |
SUBTOPIC_HEADER
SUBTOPIC_HEADER - "DSSubtopic" : messages sent by a MessageAgent
with a defined subtopic property indicate their target subtopic in this header. |
body, clientId, destination, DESTINATION_CLIENT_ID_HEADER, ENDPOINT_HEADER, FLEX_CLIENT_ID_HEADER, headers, messageId, PRIORITY_HEADER, REMOTE_CREDENTIALS_CHARSET_HEADER, REMOTE_CREDENTIALS_HEADER, REQUEST_TIMEOUT_HEADER, STATUS_CODE_HEADER, timestamp, timeToLive
Constructor and Description |
---|
AsyncMessage()
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
readExternal(java.io.ObjectInput in) |
void |
writeExternal(java.io.ObjectOutput output) |
createUUID, readFlags
public static final java.lang.String SUBTOPIC_HEADER
SUBTOPIC_HEADER
- "DSSubtopic" : messages sent by a MessageAgent
with a defined subtopic property indicate their target subtopic in this header.public java.lang.String correlationId
public void readExternal(java.io.ObjectInput in) throws java.io.IOException, java.lang.ClassNotFoundException
readExternal
in interface java.io.Externalizable
readExternal
in class AbstractMessage
java.io.IOException
java.lang.ClassNotFoundException
public void writeExternal(java.io.ObjectOutput output) throws java.io.IOException
writeExternal
in interface java.io.Externalizable
writeExternal
in class AbstractMessage
java.io.IOException