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–2021 FuseSource, Corp.. All rights reserved.