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.plist | |
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 | Field and Description |
---|---|
protected AtomicReference<Location> |
MessageDatabase.lastAsyncJournalUpdate |
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(KahaAddMessageCommand command,
Location location,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware runWithIndexLock) |
protected void |
MessageDatabase.process(KahaCommitCommand command,
Location location,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before) |
protected void |
MessageDatabase.process(KahaPrepareCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaRemoveDestinationCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaRemoveMessageCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaRewrittenDataFileCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaRollbackCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaSubscriptionCommand command,
Location location) |
protected void |
MessageDatabase.process(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) |
Location |
Journal.getNextLocation(Location location,
Location limit) |
protected Location |
Journal.recoveryCheck(DataFile dataFile) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
boolean sync) |
Location |
TargetedDataFileAppender.storeItem(ByteSequence data,
byte type,
boolean sync) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
Runnable onComplete) |
Location |
TargetedDataFileAppender.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) |
Location |
Journal.getNextLocation(Location location,
Location limit) |
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 |
---|
Location(Location item) |
WriteCommand(Location location,
ByteSequence data,
boolean sync) |
WriteCommand(Location location,
ByteSequence data,
Runnable onComplete) |
WriteKey(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 |
---|---|
Location |
PListImpl.add(Transaction tx,
String key,
Location value) |
Location |
PListImpl.addFirst(Transaction tx,
String key,
Location value) |
Modifier and Type | Method and Description |
---|---|
Location |
PListImpl.add(Transaction tx,
String key,
Location value) |
Location |
PListImpl.addFirst(Transaction tx,
String key,
Location value) |
Modifier and Type | Method and Description |
---|---|
protected void |
PListImpl.onLoad(ListNode<String,Location> node,
Transaction tx) |
void |
PListImpl.onRemove(Map.Entry<String,Location> removed) |
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,
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.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–2017 The Apache Software Foundation. All rights reserved.