|
| |
|
| java.lang.Object
 org.jboss.mq.server.MessageReference
| MessageReference | | public class MessageReference implements Comparable(Code) | | This class holds a reference to an actual Message. Where it is actually
at may vary. The reference it holds may be a:
- Hard Reference - The message is consider recently used and should not be paged out
- Soft Reference - The message is consider old and CAN be removed from memory by the GC
- No Reference - The message was removed from memory by the GC, but we can load it from a file.
author:
Hiram Chirino
author:
Peter Antman
version:
$Revision: 57198 $ |
| NOT_STORED | | final public static int NOT_STORED(Code) | | The message is not persisted
|
| REMOVED | | final public static int REMOVED(Code) | | It was a persistent message for a joint
cache store/persistent manager.
This states guards against double
removal from the cache while keeping
error checking for incorrect double removal
No message should be at this state for very long
|
| STORED | | final public static int STORED(Code) | | The message is persisted
|
| jmsDeliveryMode | | public int jmsDeliveryMode(Code) | | |
| jmsPriority | | public byte jmsPriority(Code) | | |
| messageExpiration | | public long messageExpiration(Code) | | |
| messageId | | public long messageId(Code) | | |
| messageScheduledDelivery | | public long messageScheduledDelivery(Code) | | |
| redelivered | | public boolean redelivered(Code) | | |
| redeliveryCount | | public int redeliveryCount(Code) | | |
| redeliveryDelay | | public long redeliveryDelay(Code) | | |
| referenceId | | public long referenceId(Code) | | |
| MessageReference | | MessageReference()(Code) | | |
| clear | | void clear() throws JMSException(Code) | | |
| getHeaders | | public SpyMessage.Header getHeaders() throws JMSException(Code) | | We could optimize caching by keeping the headers but not the body.
The server will uses the headers more often than the body and the
headers take up much message memory than the body
For now just return the message.
|
| getMessageForDelivery | | public SpyMessage getMessageForDelivery() throws JMSException(Code) | | |
| getPersistentKey | | public String getPersistentKey()(Code) | | Determines the persistent for storing the message
|
| inMemory | | public boolean inMemory()(Code) | | Are we entirely in memory?
true when in memory, false otherwise |
| invalidate | | public void invalidate() throws JMSException(Code) | | |
| isExpired | | public boolean isExpired()(Code) | | Returns true if this message reference has expired.
|
| isLateClone | | public boolean isLateClone()(Code) | | Are we late cloning messages?
|
| isPersistent | | public boolean isPersistent()(Code) | | Determines whether the message is persistent in the sense
that it survives a crash
|
| makeHard | | void makeHard() throws JMSException(Code) | | |
| makeSoft | | void makeSoft() throws JMSException(Code) | | |
| redelivered | | public void redelivered() throws JMSException(Code) | | The message is being redelivered
|
| removeDelayed | | public void removeDelayed() throws JMSException(Code) | | |
| setStored | | public void setStored(int stored)(Code) | | Called from A PeristenceManager/CacheStore,
to let us know that this message is already stored on disk.
|
|
|
|