Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractKahaDBStore.checkpointUpdate(Transaction tx,
boolean cleanup)
Perform the checkpoint update operation.
|
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 org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination |
TempMessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination |
MessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
long |
MessageDatabase.getStoredMessageCount(Transaction tx,
org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
String subscriptionKey) |
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(org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
Transaction tx,
int maxReturned,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
Transaction |
PageFile.tx() |
Modifier and Type | Method and Description |
---|---|
void |
Transaction.Closure.execute(Transaction tx) |
R |
Transaction.CallableClosure.execute(Transaction tx) |
Modifier and Type | Method and Description |
---|---|
protected void |
JobSchedulerStoreImpl.checkpointUpdate(Transaction tx,
boolean cleanup) |
protected void |
JobSchedulerStoreImpl.decrementJournalCount(Transaction tx,
Location location)
Removes one reference for the Journal log file indicated in the given Location value.
|
protected List<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,
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.
|
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.