| Package | Description |
|---|---|
| org.apache.activemq.store.kahadb | |
| org.apache.activemq.store.kahadb.disk.journal |
journal based data storage - scalable and fast
|
| org.apache.activemq.store.kahadb.disk.util | |
| org.apache.activemq.store.kahadb.scheduler |
| Modifier and Type | Field and Description |
|---|---|
protected Location |
MessageDatabase.Metadata.ackMessageFileMapLocation |
protected Location |
MessageDatabase.Metadata.firstInProgressTransactionLocation |
protected Location |
MessageDatabase.Metadata.lastUpdate |
protected Location |
MessageDatabase.Metadata.producerSequenceIdTrackerLocation |
| Modifier and Type | Method and Description |
|---|---|
Location[] |
MessageDatabase.getInProgressTxLocationRange() |
Location |
KahaDBMetaData.getLastUpdateLocation()
Returns the Journal Location value that indicates that last recorded update
that was successfully performed for this KahaDB store implementation.
|
Location |
AbstractKahaDBMetaData.getLastUpdateLocation() |
Location |
MessageDatabase.getLastUpdatePosition() |
Location |
MessageDatabase.store(JournalCommand<?> data) |
Location |
AbstractKahaDBStore.store(JournalCommand<?> command)
Store a command in the Journal and process to update the Store index.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync)
Store a command in the Journal and process to update the Store index.
|
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before,
Runnable after) |
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before,
Runnable after,
Runnable onJournalStoreComplete)
All updated are are funneled through this method.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync,
Runnable before,
Runnable after)
Store a command in the Journal and process to update the Store index.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync,
Runnable before,
Runnable after,
Runnable onJournalStoreComplete)
All updated are are funneled through this method.
|
Location |
MessageDatabase.store(JournalCommand<?> data,
Runnable onJournalStoreComplete) |
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
Runnable onJournalStoreComplete)
Store a command in the Journal and process to update the Store index.
|
| Modifier and Type | Method and Description |
|---|---|
JournalCommand<?> |
MultiKahaDBTransactionStore.load(Location location) |
JournalCommand<?> |
MessageDatabase.load(Location location)
Loads a previously stored JournalMessage
|
protected JournalCommand<?> |
AbstractKahaDBStore.load(Location location)
Loads a previously stored JournalMessage
|
protected abstract void |
AbstractKahaDBStore.process(JournalCommand<?> command,
Location location)
Process a stored or recovered JournalCommand instance and update the DB Index with the
state changes that this command produces.
|
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command,
Location location,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware runWithIndexLock) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaCommitCommand command,
Location location,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaPrepareCommand command,
Location location) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand command,
Location location) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command,
Location location) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaRollbackCommand command,
Location location) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand command,
Location location) |
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand command,
Location location) |
protected void |
MessageDatabase.processLocation(Location location) |
void |
KahaDBMetaData.setLastUpdateLocation(Location location)
Updates the value of the last successful update.
|
void |
AbstractKahaDBMetaData.setLastUpdateLocation(Location location) |
void |
MultiKahaDBTransactionStore.Tx.trackPrepareLocation(Location location) |
| Modifier and Type | Field and Description |
|---|---|
Location |
Journal.WriteCommand.location |
| Modifier and Type | Field and Description |
|---|---|
protected AtomicReference<Location> |
Journal.lastAppendLocation |
| Modifier and Type | Method and Description |
|---|---|
Location |
ReadOnlyJournal.getFirstLocation() |
Location |
Journal.getLastAppendLocation() |
Location |
Journal.getNextLocation(Location location) |
protected Location |
Journal.recoveryCheck(DataFile dataFile) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
boolean sync) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
Runnable onComplete) |
Location |
Journal.write(ByteSequence data,
boolean sync) |
Location |
Journal.write(ByteSequence data,
Runnable onComplete) |
| Modifier and Type | Method and Description |
|---|---|
int |
Location.compareTo(Location o) |
void |
Journal.corruptRecoveryLocation(Location recoveryPosition) |
Location |
Journal.getNextLocation(Location location) |
ByteSequence |
Journal.read(Location location) |
void |
ReplicationTarget.replicate(Location location,
ByteSequence sequence,
boolean sync) |
void |
Journal.setLastAppendLocation(Location lastSyncedLocation) |
void |
Journal.update(Location location,
ByteSequence data,
boolean sync) |
| Constructor and Description |
|---|
Journal.WriteCommand(Location location,
ByteSequence data,
boolean sync) |
Journal.WriteCommand(Location location,
ByteSequence data,
Runnable onComplete) |
Journal.WriteKey(Location item) |
Location(Location item) |
| Modifier and Type | Method and Description |
|---|---|
Location |
LocationMarshaller.deepCopy(Location source) |
Location |
LocationMarshaller.readPayload(DataInput dataIn) |
| Modifier and Type | Method and Description |
|---|---|
Location |
LocationMarshaller.deepCopy(Location source) |
void |
LocationMarshaller.writePayload(Location object,
DataOutput dataOut) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
JobSchedulerStoreImpl.decrementJournalCount(Transaction tx,
Location location)
Removes one reference for the Journal log file indicated in the given Location value.
|
protected void |
JobSchedulerStoreImpl.doRecover(JournalCommand<?> data,
Location location,
Location inDoubtlocation)
Called during index recovery to rebuild the index from the last known good location.
|
protected ByteSequence |
JobSchedulerStoreImpl.getPayload(Location location)
Retrieve the scheduled Job's byte blob from the journal.
|
protected void |
JobSchedulerStoreImpl.incrementJournalCount(Transaction tx,
Location location)
Adds a reference for the journal log file pointed to by the given Location value.
|
protected void |
JobSchedulerStoreImpl.process(JournalCommand<?> data,
Location location)
Called during recovery to allow the store to rebuild from scratch.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand command,
Location location)
Adds a new Scheduled job to the index.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand command,
Location location)
Removes all scheduled jobs within a given time range.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand command,
Location location)
Reschedules a Job after it has be fired.
|
protected void |
JobSchedulerStoreImpl.processLocation(Location location) |
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.removeInRange(Transaction tx,
long start,
long finish,
Location location)
Removes all scheduled jobs within the target range.
|
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.