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, readFlagspublic 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.ExternalizablereadExternal in class AbstractMessagejava.io.IOExceptionjava.lang.ClassNotFoundExceptionpublic void writeExternal(java.io.ObjectOutput output)
throws java.io.IOException
writeExternal in interface java.io.ExternalizablewriteExternal in class AbstractMessagejava.io.IOException