org.codehaus.activemq.store.bdbn
Class BDbMessageStore
java.lang.Object
org.codehaus.activemq.store.bdbn.BDbMessageStore
- All Implemented Interfaces:
- org.codehaus.activemq.store.MessageStore, org.codehaus.activemq.service.Service
- Direct Known Subclasses:
- BDbTopicMessageStore
- public class BDbMessageStore
- extends Object
- implements org.codehaus.activemq.store.MessageStore
An implementation of MessageStore
using
native C Berkeley DB
- Version:
- $Revision: 1.3 $
Method Summary |
org.codehaus.activemq.service.MessageIdentity |
addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
|
protected byte[] |
asBytes(org.codehaus.activemq.message.ActiveMQMessage message)
|
protected byte[] |
asBytes(String messageID)
|
protected com.sleepycat.db.Dbt |
createKey(String messageID)
|
protected org.codehaus.activemq.message.ActiveMQMessage |
extractMessage(com.sleepycat.db.Dbt value)
|
org.codehaus.activemq.message.ActiveMQMessage |
getMessage(org.codehaus.activemq.service.MessageIdentity identity)
|
void |
recover(org.codehaus.activemq.service.QueueMessageContainer container)
|
void |
removeAllMessages()
|
void |
removeMessage(org.codehaus.activemq.service.MessageIdentity identity,
org.codehaus.activemq.message.MessageAck ack)
|
void |
setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BDbMessageStore
public BDbMessageStore()
setMessageContainer
public void setMessageContainer(org.codehaus.activemq.service.MessageContainer container)
addMessage
public org.codehaus.activemq.service.MessageIdentity addMessage(org.codehaus.activemq.message.ActiveMQMessage message)
throws JMSException
- Specified by:
addMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
getMessage
public org.codehaus.activemq.message.ActiveMQMessage getMessage(org.codehaus.activemq.service.MessageIdentity identity)
throws JMSException
- Specified by:
getMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
removeMessage
public void removeMessage(org.codehaus.activemq.service.MessageIdentity identity,
org.codehaus.activemq.message.MessageAck ack)
throws JMSException
- Specified by:
removeMessage
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
recover
public void recover(org.codehaus.activemq.service.QueueMessageContainer container)
throws JMSException
- Specified by:
recover
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
start
public void start()
throws JMSException
- Specified by:
start
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
stop
public void stop()
throws JMSException
- Specified by:
stop
in interface org.codehaus.activemq.service.Service
- Throws:
JMSException
createKey
protected com.sleepycat.db.Dbt createKey(String messageID)
extractMessage
protected org.codehaus.activemq.message.ActiveMQMessage extractMessage(com.sleepycat.db.Dbt value)
throws IOException
- Throws:
IOException
asBytes
protected byte[] asBytes(org.codehaus.activemq.message.ActiveMQMessage message)
throws IOException,
JMSException
- Throws:
IOException
JMSException
asBytes
protected byte[] asBytes(String messageID)
removeAllMessages
public void removeAllMessages()
throws JMSException
- Specified by:
removeAllMessages
in interface org.codehaus.activemq.store.MessageStore
- Throws:
JMSException
- See Also:
MessageStore.removeAllMessages()
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.