|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.core.message.MessageSupport
A message base.
Field Summary | |
protected long |
expiration
GMT milliseconds at which this message expires. |
protected java.util.Map |
headers
|
protected long |
messageID
|
protected byte |
priority
|
protected boolean |
reliable
|
protected long |
timestamp
|
Fields inherited from interface org.jboss.messaging.core.message.Message |
FAILED_NODE_ID |
Constructor Summary | |
|
MessageSupport()
|
|
MessageSupport(long messageID)
|
|
MessageSupport(long messageID,
boolean reliable,
long expiration,
long timestamp,
byte priority,
java.util.Map headers,
byte[] payloadAsByteArray)
|
protected |
MessageSupport(MessageSupport that)
|
Method Summary | |
protected void |
clearPayloadAsByteArray()
|
boolean |
containsHeader(java.lang.String name)
Returns true if the Routable contains the specified header. |
protected void |
copyPayloadAsByteArrayToPayload()
It makes sense to use this method only from within JBossBytesMessage (optimization). |
boolean |
equals(java.lang.Object o)
|
long |
getExpiration()
|
java.lang.Object |
getHeader(java.lang.String name)
Returns the value corresponding to the header name. |
java.util.Set |
getHeaderNames()
Returns a copy of the header name set. |
java.util.Map |
getHeaders()
|
long |
getMessageID()
|
java.lang.Object |
getPayload()
Warning! Calling getPayload will cause the payload to be deserialized so should not be called on the server. |
byte[] |
getPayloadAsByteArray()
|
byte |
getPriority()
|
long |
getTimestamp()
|
int |
hashCode()
|
boolean |
isExpired()
|
boolean |
isPersisted()
|
boolean |
isReference()
|
boolean |
isReliable()
|
java.lang.Object |
putHeader(java.lang.String name,
java.lang.Object value)
Binds a header. |
void |
read(java.io.DataInputStream in)
|
protected java.lang.Object |
readPayload(java.io.DataInputStream in,
int length)
Override this if you want more sophisticated payload externalization. |
java.lang.Object |
removeHeader(java.lang.String name)
Removes the header. |
void |
setExpiration(long expiration)
|
void |
setHeaders(java.util.Map headers)
|
void |
setPayload(java.io.Serializable payload)
|
void |
setPersisted(boolean persisted)
|
void |
setPriority(byte priority)
|
java.lang.String |
toString()
|
void |
write(java.io.DataOutputStream out)
|
protected void |
writePayload(java.io.DataOutputStream out,
java.lang.Object thePayload)
Override this if you want more sophisticated payload externalization. |
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.jboss.messaging.core.message.Message |
getType |
Field Detail |
protected long messageID
protected boolean reliable
protected long expiration
protected long timestamp
protected java.util.Map headers
protected byte priority
Constructor Detail |
public MessageSupport()
public MessageSupport(long messageID)
public MessageSupport(long messageID, boolean reliable, long expiration, long timestamp, byte priority, java.util.Map headers, byte[] payloadAsByteArray)
protected MessageSupport(MessageSupport that)
Method Detail |
public long getMessageID()
getMessageID
in interface Message
public boolean isReliable()
isReliable
in interface Message
public long getExpiration()
getExpiration
in interface Message
public void setExpiration(long expiration)
setExpiration
in interface Message
public long getTimestamp()
getTimestamp
in interface Message
public java.lang.Object putHeader(java.lang.String name, java.lang.Object value)
Message
putHeader
in interface Message
public java.lang.Object getHeader(java.lang.String name)
Message
getHeader
in interface Message
public java.lang.Object removeHeader(java.lang.String name)
Message
removeHeader
in interface Message
public boolean containsHeader(java.lang.String name)
Message
containsHeader
in interface Message
public java.util.Set getHeaderNames()
Message
getHeaderNames
in interface Message
public java.util.Map getHeaders()
getHeaders
in interface Message
public void setHeaders(java.util.Map headers)
setHeaders
in interface Message
public byte getPriority()
getPriority
in interface Message
public void setPriority(byte priority)
setPriority
in interface Message
public boolean isReference()
public byte[] getPayloadAsByteArray()
getPayloadAsByteArray
in interface Message
public java.lang.Object getPayload()
getPayload
in interface Message
public void setPayload(java.io.Serializable payload)
protected void clearPayloadAsByteArray()
public boolean isPersisted()
isPersisted
in interface Message
public void setPersisted(boolean persisted)
setPersisted
in interface Message
public boolean isExpired()
isExpired
in interface Message
public boolean equals(java.lang.Object o)
public int hashCode()
public java.lang.String toString()
public void write(java.io.DataOutputStream out) throws java.lang.Exception
write
in interface Streamable
java.lang.Exception
public void read(java.io.DataInputStream in) throws java.lang.Exception
read
in interface Streamable
java.lang.Exception
protected void writePayload(java.io.DataOutputStream out, java.lang.Object thePayload) throws java.lang.Exception
java.lang.Exception
- TODOprotected java.lang.Object readPayload(java.io.DataInputStream in, int length) throws java.lang.Exception
java.lang.Exception
- TODOprotected final void copyPayloadAsByteArrayToPayload()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |