public final class TaskMessage extends Object implements Message
Modifier and Type | Method and Description |
---|---|
static TaskMessage |
from(String messageSourceID,
byte[] theBytes) |
byte[] |
get()
Message payload.
|
String |
getMessageSourceID() |
public static TaskMessage from(String messageSourceID, byte[] theBytes)
messageSourceID
- The message's sourceID. This will be accessible in the Driver for routing.theBytes
- The actual content of the message, serialized into a byte[]public String getMessageSourceID()
Copyright © 2017 The Apache Software Foundation. All rights reserved.