Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.service.boundedvm
Class DurableMessagePointer  view DurableMessagePointer download DurableMessagePointer.java

java.lang.Object
  extended byorg.activemq.service.boundedvm.DurableMessagePointer
All Implemented Interfaces:
org.activemq.io.util.MemoryManageable

public class DurableMessagePointer
extends java.lang.Object
implements org.activemq.io.util.MemoryManageable

DurableMessagePointers are moved around in the DurableQueueBoundedMessageManager so that we remember the associated messageStore that the message has been persisted to.

Version:
$Revision: 1.1.1.1 $

Field Summary
private  org.activemq.message.ActiveMQMessage message
           
private  org.activemq.store.MessageStore messageStore
           
 
Constructor Summary
DurableMessagePointer(org.activemq.store.MessageStore messageStore, org.activemq.message.ActiveMQDestination destination, org.activemq.message.ActiveMQMessage message)
           
 
Method Summary
 int decrementMemoryReferenceCount()
          Decrement reference count for bounded memory collections
 java.lang.Object getMemoryId()
          Get an id that can be used to identify the object.
 int getMemoryUsage()
          Get a hint about how much memory this Packet is consuming
 int getMemoryUsageReferenceCount()
           
 org.activemq.message.ActiveMQMessage getMessage()
           
 org.activemq.store.MessageStore getMessageStore()
           
 int getPriority()
           
 int incrementDeliveryCount()
           
 int incrementMemoryReferenceCount()
          Increment reference count for bounded memory collections
 int incrementRedeliveryCount()
           
 java.lang.String toString()
          Convert this Object to a human-readable String.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

messageStore

private final org.activemq.store.MessageStore messageStore

message

private final org.activemq.message.ActiveMQMessage message
Constructor Detail

DurableMessagePointer

public DurableMessagePointer(org.activemq.store.MessageStore messageStore,
                             org.activemq.message.ActiveMQDestination destination,
                             org.activemq.message.ActiveMQMessage message)
Method Detail

getMessage

public org.activemq.message.ActiveMQMessage getMessage()

getMemoryId

public java.lang.Object getMemoryId()
Description copied from interface: org.activemq.io.util.MemoryManageable
Get an id that can be used to identify the object.

Specified by:
getMemoryId in interface org.activemq.io.util.MemoryManageable

getMemoryUsage

public int getMemoryUsage()
Description copied from interface: org.activemq.io.util.MemoryManageable
Get a hint about how much memory this Packet is consuming

Specified by:
getMemoryUsage in interface org.activemq.io.util.MemoryManageable

incrementMemoryReferenceCount

public int incrementMemoryReferenceCount()
Description copied from interface: org.activemq.io.util.MemoryManageable
Increment reference count for bounded memory collections

Specified by:
incrementMemoryReferenceCount in interface org.activemq.io.util.MemoryManageable

decrementMemoryReferenceCount

public int decrementMemoryReferenceCount()
Description copied from interface: org.activemq.io.util.MemoryManageable
Decrement reference count for bounded memory collections

Specified by:
decrementMemoryReferenceCount in interface org.activemq.io.util.MemoryManageable

getMemoryUsageReferenceCount

public int getMemoryUsageReferenceCount()
Specified by:
getMemoryUsageReferenceCount in interface org.activemq.io.util.MemoryManageable

incrementDeliveryCount

public int incrementDeliveryCount()
                           throws javax.jms.JMSException

incrementRedeliveryCount

public int incrementRedeliveryCount()
                             throws javax.jms.JMSException

getMessageStore

public org.activemq.store.MessageStore getMessageStore()

toString

public java.lang.String toString()
Description copied from class: java.lang.Object
Convert this Object to a human-readable String. There are no limits placed on how long this String should be or what it should contain. We suggest you make it as intuitive as possible to be able to place it into System.out.println() 55 and such.

It is typical, but not required, to ensure that this method never completes abruptly with a java.lang.RuntimeException.

This method will be called when performing string concatenation with this object. If the result is null, string concatenation will instead use "null".

The default implementation returns getClass().getName() + "@" + Integer.toHexString(hashCode()).


getPriority

public int getPriority()
Specified by:
getPriority in interface org.activemq.io.util.MemoryManageable