Package | Description |
---|---|
org.apache.activemq.store.kahadb | |
org.apache.kahadb.journal |
journal based data storage - scalable and fast
|
org.apache.kahadb.util |
Modifier and Type | Field and Description |
---|---|
protected Location |
MessageDatabase.Metadata.firstInProgressTransactionLocation |
protected Location |
MessageDatabase.Metadata.lastUpdate |
protected Location |
MessageDatabase.Metadata.producerSequenceIdTrackerLocation |
Modifier and Type | Method and Description |
---|---|
Location |
MessageDatabase.getFirstInProgressTxLocation() |
Location |
MessageDatabase.getLastUpdatePosition() |
Location |
MessageDatabase.store(JournalCommand<?> data) |
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
Runnable before,
Runnable after) |
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
Runnable before,
Runnable after,
Runnable onJournalStoreComplete)
All updated are are funneled through this method.
|
Location |
MessageDatabase.store(JournalCommand<?> data,
Runnable onJournalStoreComplete) |
Modifier and Type | Method and Description |
---|---|
JournalCommand<?> |
MessageDatabase.load(Location location)
Loads a previously stored JournalMessage
|
JournalCommand<?> |
MultiKahaDBTransactionStore.load(Location location) |
protected void |
MessageDatabase.process(KahaAddMessageCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaCommitCommand command,
Location location,
Runnable after) |
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(KahaRollbackCommand command,
Location location) |
protected void |
MessageDatabase.process(KahaSubscriptionCommand command,
Location location) |
protected void |
MessageDatabase.processLocation(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(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly) |
Location |
Journal.getNextLocation(File file,
Location lastLocation,
boolean thisFileOnly) |
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 |
---|---|
void |
Journal.appendedExternally(Location loc,
int length) |
int |
Location.compareTo(Location o) |
Location |
Journal.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly) |
Location |
Journal.getNextLocation(File file,
Location lastLocation,
boolean thisFileOnly) |
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) |
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.