|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.jboss.messaging.core.impl.message.MessageSupport
public abstract class 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 java.lang.Object |
payload
|
protected byte[] |
payloadAsByteArray
|
protected byte |
priority
|
protected boolean |
reliable
|
protected long |
timestamp
|
| Fields inherited from interface org.jboss.messaging.core.contract.Message |
|---|
CLUSTER_SUCKED, SOURCE_CHANNEL_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 | |
|---|---|
boolean |
containsHeader(java.lang.String name)
Returns true if the Routable contains the specified header. |
MessageReference |
createReference()
|
protected void |
doWriteObject(java.io.DataOutputStream out,
java.lang.Object payload)
|
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.Map |
getHeaders()
|
long |
getMessageID()
|
java.lang.Object |
getPayload()
|
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)
|
java.lang.Object |
removeHeader(java.lang.String name)
Removes the header. |
void |
setExpiration(long expiration)
Set the expiration for this message |
void |
setPayload(java.lang.Object payload)
|
void |
setPersisted(boolean persisted)
|
void |
setPriority(byte priority)
Get the priority of the message. |
java.lang.String |
toString()
|
void |
write(java.io.DataOutputStream out)
|
| Methods inherited from class java.lang.Object |
|---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface org.jboss.messaging.core.contract.Message |
|---|
getType |
| Field Detail |
|---|
protected long messageID
protected boolean reliable
protected long expiration
protected long timestamp
protected java.util.Map headers
protected byte priority
protected transient java.lang.Object payload
protected byte[] payloadAsByteArray
| 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)
Message
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.Map getHeaders()
getHeaders in interface Messagepublic byte getPriority()
getPriority in interface Messagepublic void setPriority(byte priority)
Message
setPriority in interface Messagepublic boolean isReference()
public byte[] getPayloadAsByteArray()
getPayloadAsByteArray in interface Messagepublic java.lang.Object getPayload()
getPayload in interface Messagepublic void setPayload(java.lang.Object payload)
public boolean isExpired()
isExpired in interface Messagepublic MessageReference createReference()
createReference in interface Messagepublic boolean isPersisted()
isPersisted in interface Messagepublic void setPersisted(boolean persisted)
setPersisted in interface Messagepublic boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Object
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 doWriteObject(java.io.DataOutputStream out,
java.lang.Object payload)
throws java.io.IOException
java.io.IOException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||