public class Message
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
protected short |
flags |
protected long |
msgId |
protected OID |
msgInstanceOid |
protected MessageType |
msgType |
protected MessageAgent.RemoteAgent |
remoteAgent |
Constructor and Description |
---|
Message() |
Message(MessageType msgType)
Create message of the given message type.
|
Modifier and Type | Method and Description |
---|---|
long |
getEnqueueTime()
Get the message enqueue time.
|
long |
getMsgId()
Get the message id.
|
OID |
getMsgInstanceOid()
Get the message type.
|
MessageType |
getMsgType()
Get the message type.
|
java.lang.String |
getSenderName()
Get the sending agent name.
|
boolean |
isRPC()
True if the message is an RPC request.
|
void |
setEnqueueTime()
Set the message enqueue time to the current nano-second time.
|
void |
setEnqueueTime(long when)
Set the message enqueue time.
|
void |
setMsgInstanceOid(OID instanceOid)
Set the message type.
|
void |
setMsgType(MessageType msgType)
Set the message type.
|
static AOByteBuffer |
toBytes(Message message) |
static void |
toBytes(Message message,
AOByteBuffer buffer)
Internal use only.
|
static void |
toBytes(Message message,
java.util.Queue<AOByteBuffer> queue) |
java.lang.String |
ToString() |
protected long msgId
protected MessageType msgType
protected OID msgInstanceOid
protected short flags
protected transient MessageAgent.RemoteAgent remoteAgent
public Message()
public Message(MessageType msgType)
public MessageType getMsgType()
public void setMsgType(MessageType msgType)
public long getMsgId()
public java.lang.String getSenderName()
public long getEnqueueTime()
public void setEnqueueTime(long when)
public void setEnqueueTime()
public OID getMsgInstanceOid()
public void setMsgInstanceOid(OID instanceOid)
public static void toBytes(Message message, java.util.Queue<AOByteBuffer> queue)
public static AOByteBuffer toBytes(Message message)
public static void toBytes(Message message, AOByteBuffer buffer)
public java.lang.String ToString()
public boolean isRPC()