A B C D E G I O P R S T

A

addMessage(ActiveMQMessage) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
asBytes(ActiveMQMessage) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
asBytes(String) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 

B

BDbHelper - class org.codehaus.activemq.store.bdbn.BDbHelper.
Some helper factory methods for creating default configured Berkeley DB objects
BDbHelper() - Constructor for class org.codehaus.activemq.store.bdbn.BDbHelper
 
BDbMessageStore - class org.codehaus.activemq.store.bdbn.BDbMessageStore.
An implementation of MessageStore using native C Berkeley DB
BDbMessageStore() - Constructor for class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
BDbPersistenceAdapter - class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter.
 
BDbPersistenceAdapter(DbEnv) - Constructor for class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
BDbTopicMessageStore - class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore.
An implementation of TopicMessageStore using native C Berkeley DB
BDbTopicMessageStore() - Constructor for class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
beginTransaction() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 

C

commitTransaction(DbTxn) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
Commit a transaction, throwing a JMSException if a failure occurs to avoid TRA rolling back
commitTransaction() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
createDatabase(String) - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
createEnvironment(File, boolean) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
 
createKey(String) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
createPreparedTransactionStore() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
createQueueMessageStore(String) - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
createTopicMessageStore(String) - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
createTransaction(DbEnv) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
 

D

dataToObject(DataBuffer) - Method in class org.codehaus.activemq.store.bdbn.StringDataBinding
 
decrementMessageCountAndMaybeDelete(MessageIdentity, MessageAck) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 

E

environment - Variable in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
extractMessage(Dbt) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 

G

getDataFormat() - Method in class org.codehaus.activemq.store.bdbn.StringDataBinding
 
getInitialDestinations() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
getLastestMessageIdentity() - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
getMessage(MessageIdentity) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
getSubscriberEntry(ConsumerInfo) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
getTransaction() - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
 
getTransactionCount() - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
 

I

incrementMessageCount(MessageIdentity) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 

O

objectToData(Object, DataBuffer) - Method in class org.codehaus.activemq.store.bdbn.StringDataBinding
 
open(DbEnv, String, boolean) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
 
org.codehaus.activemq.store.bdbn - package org.codehaus.activemq.store.bdbn
Message persistence implemented using Berkeley DB, native C version

P

popTransaction() - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
Pops off the current transaction from the stack
pushTransaction(DbTxn) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
Sets the current transaction, possibly including nesting

R

recover(QueueMessageContainer) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
recoverSubscription(Subscription, MessageIdentity) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
removeAllMessages() - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
removeMessage(MessageIdentity, MessageAck) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
rollbackTransaction(DbTxn) - Static method in class org.codehaus.activemq.store.bdbn.BDbHelper
Rolls back the transaction, catching all exceptions as we only rollback if we are about to throw an exception anyways
rollbackTransaction() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 

S

StringDataBinding - class org.codehaus.activemq.store.bdbn.StringDataBinding.
A DataBinding for a simple String serialiation
StringDataBinding() - Constructor for class org.codehaus.activemq.store.bdbn.StringDataBinding
 
StringDataFormat - class org.codehaus.activemq.store.bdbn.StringDataFormat.
 
StringDataFormat() - Constructor for class org.codehaus.activemq.store.bdbn.StringDataFormat
 
setLastAcknowledgedMessageIdentity(Subscription, MessageIdentity) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
setMessageContainer(MessageContainer) - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
setSubscriberEntry(ConsumerInfo, SubscriberEntry) - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 
start() - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
start() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
stop() - Method in class org.codehaus.activemq.store.bdbn.BDbMessageStore
 
stop() - Method in class org.codehaus.activemq.store.bdbn.BDbPersistenceAdapter
 
stop() - Method in class org.codehaus.activemq.store.bdbn.BDbTopicMessageStore
 

T

TRANSACTION_FLAGS - Static variable in class org.codehaus.activemq.store.bdbn.BDbHelper
 

A B C D E G I O P R S T

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