Uses of Class
org.apache.activemq.store.kahadb.disk.page.Transaction
-
-
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 subscriptionprotected 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 MessageStoreStatisticsvoid
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 indexvoid
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 indexesvoid
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, itemValue
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 keyValue
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 indexesvoid
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.
-