|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Location | |
---|---|
org.apache.activemq.store.kahadb | |
org.apache.kahadb.journal | journal based data storage - scalable and fast |
org.apache.kahadb.util |
Uses of Location in org.apache.activemq.store.kahadb |
---|
Fields in org.apache.activemq.store.kahadb declared as Location | |
---|---|
protected Location |
MessageDatabase.Metadata.firstInProgressTransactionLocation
|
protected Location |
MessageDatabase.Metadata.lastUpdate
|
protected Location |
MessageDatabase.Metadata.producerSequenceIdTrackerLocation
|
Methods in org.apache.activemq.store.kahadb that return Location | |
---|---|
Location |
MessageDatabase.getFirstInProgressTxLocation()
|
Location |
MessageDatabase.getLastUpdatePosition()
|
Location |
MessageDatabase.store(JournalCommand<?> data)
|
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
java.lang.Runnable before,
java.lang.Runnable after)
|
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
java.lang.Runnable before,
java.lang.Runnable after,
java.lang.Runnable onJournalStoreComplete)
All updated are are funneled through this method. |
Location |
MessageDatabase.store(JournalCommand<?> data,
java.lang.Runnable onJournalStoreComplete)
|
Methods in org.apache.activemq.store.kahadb with parameters of type Location | |
---|---|
JournalCommand<?> |
MessageDatabase.load(Location location)
Loads a previously stored JournalMessage |
JournalCommand<?> |
MultiKahaDBTransactionStore.load(Location location)
|
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command,
Location location)
|
protected void |
MessageDatabase.process(org.apache.activemq.store.kahadb.data.KahaCommitCommand command,
Location location,
java.lang.Runnable after)
|
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.processLocation(Location location)
|
void |
MultiKahaDBTransactionStore.Tx.trackPrepareLocation(Location location)
|
Uses of Location in org.apache.kahadb.journal |
---|
Fields in org.apache.kahadb.journal declared as Location | |
---|---|
Location |
Journal.WriteCommand.location
|
Fields in org.apache.kahadb.journal with type parameters of type Location | |
---|---|
protected java.util.concurrent.atomic.AtomicReference<Location> |
Journal.lastAppendLocation
|
Methods in org.apache.kahadb.journal that return Location | |
---|---|
Location |
ReadOnlyJournal.getFirstLocation()
|
Location |
Journal.getLastAppendLocation()
|
Location |
Journal.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly)
|
Location |
Journal.getNextLocation(java.io.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,
java.lang.Runnable onComplete)
|
Location |
Journal.write(ByteSequence data,
boolean sync)
|
Location |
Journal.write(ByteSequence data,
java.lang.Runnable onComplete)
|
Methods in org.apache.kahadb.journal with parameters of type Location | |
---|---|
void |
Journal.appendedExternally(Location loc,
int length)
|
int |
Location.compareTo(Location o)
|
Location |
Journal.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly)
|
Location |
Journal.getNextLocation(java.io.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)
|
Constructors in org.apache.kahadb.journal with parameters of type Location | |
---|---|
Journal.WriteCommand(Location location,
ByteSequence data,
boolean sync)
|
|
Journal.WriteCommand(Location location,
ByteSequence data,
java.lang.Runnable onComplete)
|
|
Journal.WriteKey(Location item)
|
|
Location(Location item)
|
Uses of Location in org.apache.kahadb.util |
---|
Methods in org.apache.kahadb.util that return Location | |
---|---|
Location |
LocationMarshaller.deepCopy(Location source)
|
Location |
LocationMarshaller.readPayload(java.io.DataInput dataIn)
|
Methods in org.apache.kahadb.util with parameters of type Location | |
---|---|
Location |
LocationMarshaller.deepCopy(Location source)
|
void |
LocationMarshaller.writePayload(Location object,
java.io.DataOutput dataOut)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |