Package org.apache.activemq.store.kahadb

Class TempKahaDBStore.KahaDBMessageStore

java.lang.Object

org.apache.activemq.store.AbstractMessageStore

org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

All Implemented Interfaces:

org.apache.activemq.Service, MessageStore

Enclosing class:

TempKahaDBStore

public class TempKahaDBStore.KahaDBMessageStore
extends AbstractMessageStore

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.store.MessageStore

MessageStore.StoreType

Field Summary

Fields

Modifier and Type	Field	Description
protected KahaDestination	dest

Fields inherited from class org.apache.activemq.store.AbstractMessageStore

destination, FUTURE, indexListener, messageStoreStatistics, prioritizedMessages

Constructor Summary

Constructors

Constructor	Description
KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)

Method Summary

Modifier and Type	Method	Description
void	addMessage(ConnectionContext context, org.apache.activemq.command.Message message)
org.apache.activemq.command.ActiveMQDestination	getDestination()
org.apache.activemq.command.Message	getMessage(org.apache.activemq.command.MessageId identity)
MessageStore.StoreType	getType()
void	recover(MessageRecoveryListener listener)
void	recoverMessageStoreStatistics()
void	recoverNextMessages(int maxReturned, MessageRecoveryListener listener)
void	removeAllMessages(ConnectionContext context)
void	removeMessage(ConnectionContext context, org.apache.activemq.command.MessageAck ack)
void	resetBatching()
void	setBatch(org.apache.activemq.command.MessageId identity)
void	setMemoryUsage(MemoryUsage memoryUsage)
void	start()
void	stop()

Methods inherited from class org.apache.activemq.store.AbstractMessageStore

addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getIndexListener, getMessageCount, getMessageSize, getMessageStoreStatistics, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setPrioritizedMessages, updateMessage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.store.MessageStore

recoverMessages

Field Details

dest

protected KahaDestination dest

Constructor Details

KahaDBMessageStore

public KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)

Method Details

getDestination

public org.apache.activemq.command.ActiveMQDestination getDestination()

Specified by:

getDestination in interface MessageStore

Overrides:

getDestination in class AbstractMessageStore

addMessage

public void addMessage(ConnectionContext context,
 org.apache.activemq.command.Message message)
                throws IOException

Throws:

IOException

removeMessage

public void removeMessage(ConnectionContext context,
 org.apache.activemq.command.MessageAck ack)
                   throws IOException

Throws:

IOException

removeAllMessages

public void removeAllMessages(ConnectionContext context)
                       throws IOException

Throws:

IOException

getMessage

public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId identity)
                                               throws IOException

Throws:

IOException

recover

public void recover(MessageRecoveryListener listener)
             throws Exception

Throws:

Exception

recoverNextMessages

public void recoverNextMessages(int maxReturned,
 MessageRecoveryListener listener)
                         throws Exception

Throws:

Exception

resetBatching

public void resetBatching()

setBatch

public void setBatch(org.apache.activemq.command.MessageId identity)
              throws IOException

Specified by:

setBatch in interface MessageStore

Overrides:

setBatch in class AbstractMessageStore

Throws:

IOException

setMemoryUsage

public void setMemoryUsage(MemoryUsage memoryUsage)

Specified by:

setMemoryUsage in interface MessageStore

Overrides:

setMemoryUsage in class AbstractMessageStore

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.Service

Overrides:

start in class AbstractMessageStore

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.Service

Overrides:

stop in class AbstractMessageStore

Throws:

Exception

recoverMessageStoreStatistics

public void recoverMessageStoreStatistics()
                                   throws IOException

Overrides:

recoverMessageStoreStatistics in class AbstractMessageStore

Throws:

IOException

getType

public MessageStore.StoreType getType()