|
|||||||||||
| 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 Messagepublic boolean isReliable()
isReliable in interface Messagepublic long getExpiration()
getExpiration in interface Messagepublic void setExpiration(long expiration)
setExpiration in interface Messagepublic long getTimestamp()
getTimestamp in interface Message
public java.lang.Object putHeader(java.lang.String name,
java.lang.Object value)
Message
putHeader in interface Messagepublic java.lang.Object getHeader(java.lang.String name)
Message
getHeader in interface Messagepublic java.lang.Object removeHeader(java.lang.String name)
Message
removeHeader in interface Messagepublic boolean containsHeader(java.lang.String name)
Message
containsHeader in interface Messagepublic java.util.Set getHeaderNames()
Message
getHeaderNames in interface Messagepublic java.util.Map getHeaders()
getHeaders in interface Messagepublic void setHeaders(java.util.Map headers)
setHeaders in interface Messagepublic byte getPriority()
getPriority in interface Messagepublic void setPriority(byte priority)
setPriority in interface Messagepublic boolean isReference()
public byte[] getPayloadAsByteArray()
getPayloadAsByteArray in interface Messagepublic java.lang.Object getPayload()
getPayload in interface Messagepublic void setPayload(java.io.Serializable payload)
protected void clearPayloadAsByteArray()
public boolean isPersisted()
isPersisted in interface Messagepublic void setPersisted(boolean persisted)
setPersisted in interface Messagepublic boolean isExpired()
isExpired in interface Messagepublic 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 Streamablejava.lang.Exception
public void read(java.io.DataInputStream in)
throws java.lang.Exception
read in interface Streamablejava.lang.Exception
protected void writePayload(java.io.DataOutputStream out,
java.lang.Object thePayload)
throws java.lang.Exception
java.lang.Exception - TODO
protected 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 | ||||||||||