|
||||||||||
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 |
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
|
Methods in org.apache.activemq.store.kahadb that return Location | |
---|---|
Location |
MessageDatabase.getLastUpdatePosition()
|
Location |
MessageDatabase.store(JournalCommand data)
|
Location |
MessageDatabase.store(JournalCommand data,
boolean sync)
All updated are are funneled through this method. |
Methods in org.apache.activemq.store.kahadb with parameters of type Location | |
---|---|
JournalCommand |
MessageDatabase.load(Location location)
Loads a previously stored JournalMessage |
protected void |
MessageDatabase.process(KahaCommitCommand command,
Location location)
|
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)
|
Uses of Location in org.apache.kahadb.journal |
---|
Fields in org.apache.kahadb.journal with type parameters of type Location | |
---|---|
protected 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(File file,
Location lastLocation,
boolean thisFileOnly)
|
Location |
Journal.getNextLocation(Location location)
|
protected Location |
Journal.recoveryCheck(DataFile dataFile)
|
Location |
Journal.write(ByteSequence data,
boolean sync)
|
Location |
Journal.write(ByteSequence data,
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(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 | |
---|---|
Location(Location item)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |