Uses of Class
org.apache.activemq.store.kahadb.disk.journal.Location

Packages that use Location
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   
 

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.getInProgressTxLocationRange()
           
 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)
           
 

Methods in org.apache.activemq.store.kahadb with parameters of type Location
 JournalCommand<?> MultiKahaDBTransactionStore.load(Location location)
           
 JournalCommand<?> MessageDatabase.load(Location location)
          Loads a previously stored JournalMessage
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)
           
 

Uses of Location in org.apache.activemq.store.kahadb.disk.journal
 

Fields in org.apache.activemq.store.kahadb.disk.journal declared as Location
 Location Journal.WriteCommand.location
           
 

Fields in org.apache.activemq.store.kahadb.disk.journal with type parameters of type Location
protected  AtomicReference<Location> Journal.lastAppendLocation
           
 

Methods in org.apache.activemq.store.kahadb.disk.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 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)
           
 

Methods in org.apache.activemq.store.kahadb.disk.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.activemq.store.kahadb.disk.journal with parameters of type Location
Journal.WriteCommand(Location location, ByteSequence data, boolean sync)
           
Journal.WriteCommand(Location location, ByteSequence data, Runnable onComplete)
           
Journal.WriteKey(Location item)
           
Location(Location item)
           
 

Uses of Location in org.apache.activemq.store.kahadb.disk.util
 

Methods in org.apache.activemq.store.kahadb.disk.util that return Location
 Location LocationMarshaller.deepCopy(Location source)
           
 Location LocationMarshaller.readPayload(DataInput dataIn)
           
 

Methods in org.apache.activemq.store.kahadb.disk.util with parameters of type Location
 Location LocationMarshaller.deepCopy(Location source)
           
 void LocationMarshaller.writePayload(Location object, DataOutput dataOut)
           
 



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.