Uses of Class
org.apache.activemq.store.kahadb.disk.page.Transaction

Packages that use Transaction

Package	Description
org.apache.activemq.store.kahadb
org.apache.activemq.store.kahadb.disk.index
org.apache.activemq.store.kahadb.disk.page
org.apache.activemq.store.kahadb.plist
org.apache.activemq.store.kahadb.scheduler

Uses of Transaction in org.apache.activemq.store.kahadb

Methods in org.apache.activemq.store.kahadb with parameters of type Transaction

Modifier and Type	Method	Description
protected abstract void	AbstractKahaDBStore.checkpointUpdate(Transaction tx, boolean cleanup)	Perform the checkpoint update operation.
protected void	MessageDatabase.decrementAndSubSizeToStoreStat(Transaction tx, String kahaDestKey, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, long size)
protected void	MessageDatabase.decrementAndSubSizeToStoreStat(Transaction tx, KahaDestination kahaDestination, long size)
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination	MessageDatabase.getExistingStoredDestination(KahaDestination destination, Transaction tx)
org.apache.activemq.store.kahadb.MessageDatabase.LastAck	MessageDatabase.getLastAck(Transaction tx, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, String subscriptionKey)
protected SequenceSet	MessageDatabase.getSequenceSet(Transaction tx, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, String subscriptionKey)
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination	MessageDatabase.getStoredDestination(KahaDestination destination, Transaction tx)
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination	TempMessageDatabase.getStoredDestination(KahaDestination destination, Transaction tx)
protected long	MessageDatabase.getStoredMessageCount(Transaction tx, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, String subscriptionKey)
protected long	MessageDatabase.getStoredMessageSize(Transaction tx, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, String subscriptionKey)
protected Map<String,AtomicLong>	MessageDatabase.getStoredMessageSize(Transaction tx, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, List<String> subscriptionKeys)	Recovers durable subscription pending message size with only 1 pass over the order index on recovery instead of iterating over the index once per subscription
protected MessageStoreStatistics	MessageDatabase.getStoredMessageStoreStatistics(KahaDestination destination, Transaction tx)
protected void	MessageDatabase.incrementAndAddSizeToStoreStat(Transaction tx, String kahaDestKey, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, long size)
protected void	MessageDatabase.incrementAndAddSizeToStoreStat(Transaction tx, KahaDestination kahaDestination, long size)	Update MessageStoreStatistics
void	KahaDBMetaData.initialize(Transaction tx)	For a newly created KahaDBMetaData instance this method is called to allow the instance to create all of it's internal indices and other state data.
void	KahaDBMetaData.load(Transaction tx)	Instructs this object to load its internal data structures from the KahaDB PageFile and prepare itself for use.
protected void	MessageDatabase.recoverIndex(Transaction tx)
protected int	KahaDBStore.KahaDBMessageStore.recoverRolledBackAcks(String recoveredTxStateMapKey, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, Transaction tx, int maxReturned, MessageRecoveryListener listener)

Uses of Transaction in org.apache.activemq.store.kahadb.disk.index

Methods in org.apache.activemq.store.kahadb.disk.index with parameters of type Transaction

Modifier and Type	Method	Description
Value	ListIndex.add(Transaction tx, Key key, Value value)
Value	ListIndex.addFirst(Transaction tx, Key key, Value value)
Value	ListNode.addFirst(Transaction tx, Key key, Value value)
void	BTreeIndex.clear(Transaction tx)
void	BTreeNode.clear(Transaction tx)
void	HashIndex.clear(Transaction tx)
void	Index.clear(Transaction tx)	clear the index
void	ListIndex.clear(Transaction tx)
void	ListNode.clear(Transaction tx)
boolean	BTreeNode.contains(Transaction tx, Key key)
boolean	ListNode.contains(Transaction tx, Key key)
boolean	BTreeIndex.containsKey(Transaction tx, Key key)
boolean	HashIndex.containsKey(Transaction tx, Key key)
boolean	Index.containsKey(Transaction tx, Key key)
boolean	ListIndex.containsKey(Transaction tx, Key key)
ListNode<Key,Value>	ListIndex.createNode(Transaction tx)
Value	BTreeIndex.get(Transaction tx, Key key)
Value	BTreeNode.get(Transaction tx, Key key)
Value	HashIndex.get(Transaction tx, Key key)
Value	Index.get(Transaction tx, Key key)
Value	ListIndex.get(Transaction tx, Key key)
Value	ListNode.get(Transaction tx, Key key)
Map.Entry<Key,Value>	BTreeIndex.getFirst(Transaction tx)
Map.Entry<Key,Value>	BTreeNode.getFirst(Transaction tx)
Map.Entry<Key,Value>	ListIndex.getFirst(Transaction tx)
Map.Entry<Key,Value>	ListNode.getFirst(Transaction tx)
BTreeNode<Key,Value>	BTreeNode.getFirstLeafNode(Transaction tx)
protected ListNode<Key,Value>	ListIndex.getHead(Transaction tx)
Map.Entry<Key,Value>	BTreeIndex.getLast(Transaction tx)
Map.Entry<Key,Value>	BTreeNode.getLast(Transaction tx)
Map.Entry<Key,Value>	ListIndex.getLast(Transaction tx)
Map.Entry<Key,Value>	ListNode.getLast(Transaction tx)
int	BTreeIndex.getMaxLeafDepth(Transaction tx)
int	BTreeNode.getMaxLeafDepth(Transaction tx, int depth)
int	BTreeIndex.getMinLeafDepth(Transaction tx)
int	BTreeNode.getMinLeafDepth(Transaction tx, int depth)
protected ListNode<Key,Value>	ListIndex.getTail(Transaction tx)
boolean	BTreeIndex.isEmpty(Transaction tx)
boolean	BTreeNode.isEmpty(Transaction tx)
boolean	ListIndex.isEmpty(Transaction tx)
boolean	ListNode.isEmpty(Transaction tx)
Iterator<Map.Entry<Key,Value>>	BTreeIndex.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	BTreeIndex.iterator(Transaction tx, Key initialKey)
Iterator<Map.Entry<Key,Value>>	BTreeIndex.iterator(Transaction tx, Key initialKey, Key maxKey)
Iterator<Map.Entry<Key,Value>>	BTreeNode.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	BTreeNode.iterator(Transaction tx, Key startKey, Key endKey)
Iterator<Map.Entry<Key,Value>>	HashIndex.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	Index.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	ListIndex.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	ListIndex.iterator(Transaction tx, long initialPosition)
Iterator<Map.Entry<Key,Value>>	ListNode.iterator(Transaction tx)
Iterator<Map.Entry<Key,Value>>	ListNode.iterator(Transaction tx, long pos)
Iterator<ListNode<Key,Value>>	ListIndex.listNodeIterator(Transaction tx)
void	BTreeIndex.load(Transaction tx)
void	HashIndex.load(Transaction tx)
void	Index.load(Transaction tx)	load indexes
void	ListIndex.load(Transaction tx)
protected void	ListIndex.onLoad(ListNode<Key,Value> node, Transaction tx)
void	BTreeIndex.printStructure(Transaction tx, OutputStream out)
void	BTreeIndex.printStructure(Transaction tx, PrintWriter out)
void	BTreeNode.printStructure(Transaction tx, PrintWriter out, String prefix)
Value	BTreeIndex.put(Transaction tx, Key key, Value value)
Value	BTreeNode.put(Transaction tx, Key key, Value value)
Value	HashIndex.put(Transaction tx, Key key, Value value)
Value	Index.put(Transaction tx, Key key, Value entry)	store the key, item
Value	ListIndex.put(Transaction tx, Key key, Value value)	Update the value of the item with the given key in the list if ot exists, otherwise it appends the value to the end of the list.
Value	ListNode.put(Transaction tx, Key key, Value value)
Value	BTreeIndex.remove(Transaction tx, Key key)
Value	BTreeNode.remove(Transaction tx, Key key)
Value	HashIndex.remove(Transaction tx, Key key)
Value	Index.remove(Transaction tx, Key key)	remove the index key
Value	ListIndex.remove(Transaction tx, Key key)
int	HashIndex.size(Transaction tx)
int	ListNode.size(Transaction tx)
void	HashIndex.store(Transaction tx, org.apache.activemq.store.kahadb.disk.index.HashBin<Key,Value> bin)
void	ListIndex.storeNode(Transaction tx, ListNode<Key,Value> node, boolean overflow)
void	ListNode.storeUpdate(Transaction tx)
void	BTreeIndex.unload(Transaction tx)
void	HashIndex.unload(Transaction tx)
void	Index.unload(Transaction tx)	unload indexes
void	ListIndex.unload(Transaction tx)
void	BTreeIndex.visit(Transaction tx, BTreeVisitor<Key,Value> visitor)
void	BTreeNode.visit(Transaction tx, BTreeVisitor<Key,Value> visitor)

Uses of Transaction in org.apache.activemq.store.kahadb.disk.page

Methods in org.apache.activemq.store.kahadb.disk.page that return Transaction

Modifier and Type	Method	Description
Transaction	PageFile.tx()

Methods in org.apache.activemq.store.kahadb.disk.page with parameters of type Transaction

Modifier and Type	Method	Description
R	Transaction.CallableClosure.execute(Transaction tx)
void	Transaction.Closure.execute(Transaction tx)

Uses of Transaction in org.apache.activemq.store.kahadb.plist

Methods in org.apache.activemq.store.kahadb.plist with parameters of type Transaction

Modifier and Type	Method	Description
Location	PListImpl.add(Transaction tx, String key, Location value)
Location	PListImpl.addFirst(Transaction tx, String key, Location value)
void	PListImpl.clear(Transaction tx)
protected void	PListImpl.onLoad(ListNode<String,Location> node, Transaction tx)

Uses of Transaction in org.apache.activemq.store.kahadb.scheduler

Methods in org.apache.activemq.store.kahadb.scheduler with parameters of type Transaction

Modifier and Type	Method	Description
protected void	JobSchedulerStoreImpl.checkpointUpdate(Transaction tx, boolean cleanup)
protected void	JobSchedulerStoreImpl.decrementJournalCount(Transaction tx, HashMap<Integer,Integer> decrementsByFileIds)	Removes multiple references for the Journal log file indicated in the given Location map.
protected void	JobSchedulerStoreImpl.decrementJournalCount(Transaction tx, Location location)	Removes one reference for the Journal log file indicated in the given Location value.
protected Iterator<org.apache.activemq.store.kahadb.scheduler.JobLocation>	JobSchedulerImpl.getAllScheduledJobs(Transaction tx)	Walks the Scheduled Job Tree and collects the add location and last update location for all scheduled jobs.
protected void	JobSchedulerStoreImpl.incrementJournalCount(Transaction tx, Location location)	Adds a reference for the journal log file pointed to by the given Location value.
void	JobSchedulerKahaDBMetaData.initialize(Transaction tx)
void	JobSchedulerKahaDBMetaData.load(Transaction tx)
void	JobSchedulerKahaDBMetaData.loadScheduler(Transaction tx, Map<String,JobSchedulerImpl> schedulers)	Loads all the stored JobScheduler instances into the provided map.
protected void	JobSchedulerImpl.process(Transaction tx, KahaAddScheduledJobCommand command, Location location)	Adds a new Scheduled job to the index.
protected void	JobSchedulerImpl.process(Transaction tx, KahaRemoveScheduledJobsCommand command, Location location)	Removes all scheduled jobs within a given time range.
protected void	JobSchedulerImpl.process(Transaction tx, KahaRescheduleJobCommand command, Location location)	Reschedules a Job after it has be fired.
protected void	JobSchedulerStoreImpl.referenceRemovedLocation(Transaction tx, Location location, List<Integer> removedJobsFileId)	Updates the Job removal tracking index with the location of a remove command and the original JobLocation entry.
protected void	JobSchedulerStoreImpl.referenceRemovedLocation(Transaction tx, Location location, org.apache.activemq.store.kahadb.scheduler.JobLocation removedJob)	Updates the Job removal tracking index with the location of a remove command and the original JobLocation entry.
protected void	JobSchedulerImpl.removeAll(Transaction tx)	Removes all jobs from the schedulers index.
protected void	JobSchedulerImpl.removeInRange(Transaction tx, long start, long finish, Location location)	Removes all scheduled jobs within the target range.
protected boolean	JobSchedulerImpl.removeJobAtTime(Transaction tx, String jobId, long executionTime)	Removes a Job from the index using it's Id value and the time it is currently set to be executed.