org.activemq.store.vm
Class VMMessageStore

java.lang.Object
  extended by org.activemq.store.vm.VMMessageStore
All Implemented Interfaces:
Service, MessageStore
Direct Known Subclasses:
VMTopicMessageStore

public class VMMessageStore
extends Object
implements MessageStore

An implementation of MessageStore which uses a

Version:
$Revision: 1.1.1.1 $

Field Summary
protected  MessageIdentity lastMessageIdentity
           
protected  Map messageTable
           
 
Constructor Summary
VMMessageStore()
           
VMMessageStore(LinkedHashMap messageTable)
           
 
Method Summary
 void addMessage(ActiveMQMessage message)
          Adds a message to the message store
 ActiveMQMessage getMessage(MessageIdentity identity)
          Looks up a message using either the String messageID or the messageNumber.
 void recover(RecoveryListener listener)
          Recover any messages to be delivered.
 void removeAllMessages()
          Removes all the messages from the message store.
 void removeMessage(MessageAck ack)
          Removes a message from the message store.
 void removeMessage(MessageIdentity msgId)
           
 void start()
          Called to start the service
 void stop()
          Called to shutdown the service
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

messageTable

protected Map messageTable

lastMessageIdentity

protected MessageIdentity lastMessageIdentity
Constructor Detail

VMMessageStore

public VMMessageStore()

VMMessageStore

public VMMessageStore(LinkedHashMap messageTable)
Method Detail

addMessage

public void addMessage(ActiveMQMessage message)
                throws JMSException
Description copied from interface: MessageStore
Adds a message to the message store

Specified by:
addMessage in interface MessageStore
Throws:
JMSException

getMessage

public ActiveMQMessage getMessage(MessageIdentity identity)
                           throws JMSException
Description copied from interface: MessageStore
Looks up a message using either the String messageID or the messageNumber. Implementations are encouraged to fill in the missing key if its easy to do so.

Specified by:
getMessage in interface MessageStore
Parameters:
identity - which contains either the messageID or the messageNumber
Returns:
the message or null if it does not exist
Throws:
JMSException

removeMessage

public void removeMessage(MessageAck ack)
                   throws JMSException
Description copied from interface: MessageStore
Removes a message from the message store.

Specified by:
removeMessage in interface MessageStore
Parameters:
ack - the ack request that cause the message to be removed. It conatins the identity which contains the messageID of the message that needs to be removed.
Throws:
JMSException

removeMessage

public void removeMessage(MessageIdentity msgId)
                   throws JMSException
Throws:
JMSException

recover

public void recover(RecoveryListener listener)
             throws JMSException
Description copied from interface: MessageStore
Recover any messages to be delivered.

Specified by:
recover in interface MessageStore
Throws:
JMSException

start

public void start()
           throws JMSException
Description copied from interface: Service
Called to start the service

Specified by:
start in interface Service
Throws:
JMSException

stop

public void stop()
          throws JMSException
Description copied from interface: Service
Called to shutdown the service

Specified by:
stop in interface Service
Throws:
JMSException

removeAllMessages

public void removeAllMessages()
                       throws JMSException
Description copied from interface: MessageStore
Removes all the messages from the message store.

Specified by:
removeAllMessages in interface MessageStore
Throws:
JMSException


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.