|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Location | |
---|---|
org.apache.activemq.console.command.store.amq | |
org.apache.activemq.kaha | fast message persistence implementation |
org.apache.activemq.kaha.impl.async | journal based data storage - scalable and fast |
org.apache.activemq.store.amq | The default Store implementation for ActiveMQ |
Uses of Location in org.apache.activemq.console.command.store.amq |
---|
Methods in org.apache.activemq.console.command.store.amq that return Location | |
---|---|
Location |
Entry.getLocation()
|
Methods in org.apache.activemq.console.command.store.amq with parameters of type Location | |
---|---|
void |
Entry.setLocation(Location location)
|
Uses of Location in org.apache.activemq.kaha |
---|
Fields in org.apache.activemq.kaha declared as Location | |
---|---|
Location |
MessageAckWithLocation.location
|
Constructors in org.apache.activemq.kaha with parameters of type Location | |
---|---|
MessageAckWithLocation(MessageAck ack,
Location location)
|
Uses of Location in org.apache.activemq.kaha.impl.async |
---|
Fields in org.apache.activemq.kaha.impl.async declared as Location | |
---|---|
protected Location |
AsyncDataManager.mark
|
Fields in org.apache.activemq.kaha.impl.async with type parameters of type Location | |
---|---|
protected java.util.concurrent.atomic.AtomicReference<Location> |
AsyncDataManager.lastAppendLocation
|
Methods in org.apache.activemq.kaha.impl.async that return Location | |
---|---|
Location |
ReadOnlyAsyncDataManager.getFirstLocation()
|
Location |
AsyncDataManager.getLastAppendLocation()
|
Location |
JournalFacade.RecordLocationFacade.getLocation()
|
Location |
AsyncDataManager.getMark()
|
Location |
AsyncDataManager.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly)
|
Location |
AsyncDataManager.getNextLocation(java.io.File file,
Location lastLocation,
boolean thisFileOnly)
|
Location |
AsyncDataManager.getNextLocation(Location location)
|
protected Location |
AsyncDataManager.recoveryCheck(DataFile dataFile,
Location location)
|
Location |
AsyncDataManager.write(ByteSequence data,
boolean sync)
|
Location |
AsyncDataManager.write(ByteSequence data,
byte type,
boolean sync)
|
Location |
AsyncDataManager.write(ByteSequence data,
java.lang.Runnable onComplete)
|
Methods in org.apache.activemq.kaha.impl.async with parameters of type Location | |
---|---|
int |
Location.compareTo(Location o)
|
long |
AsyncDataManager.getDiskSizeUntil(Location startPosition)
|
Location |
AsyncDataManager.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly)
|
Location |
AsyncDataManager.getNextLocation(java.io.File file,
Location lastLocation,
boolean thisFileOnly)
|
Location |
AsyncDataManager.getNextLocation(Location location)
|
ByteSequence |
AsyncDataManager.read(Location location)
|
protected Location |
AsyncDataManager.recoveryCheck(DataFile dataFile,
Location location)
|
void |
AsyncDataManager.removeLocation(Location location)
|
void |
AsyncDataManager.setLastAppendLocation(Location lastSyncedLocation)
|
void |
AsyncDataManager.setMark(Location location,
boolean sync)
|
void |
AsyncDataManager.update(Location location,
ByteSequence data,
boolean sync)
|
Constructors in org.apache.activemq.kaha.impl.async with parameters of type Location | |
---|---|
JournalFacade.RecordLocationFacade(Location location)
|
Uses of Location in org.apache.activemq.store.amq |
---|
Fields in org.apache.activemq.store.amq declared as Location | |
---|---|
protected Location |
AMQMessageStore.lastLocation
|
protected Location |
AMQMessageStore.lastWrittenLocation
|
Fields in org.apache.activemq.store.amq with type parameters of type Location | |
---|---|
protected java.util.Set<Location> |
AMQMessageStore.inFlightTxLocations
|
Methods in org.apache.activemq.store.amq that return Location | |
---|---|
Location |
AMQTransactionStore.checkpoint()
|
protected Location |
AMQMessageStore.doAsyncWrite()
|
Location |
AMQTxOperation.getLocation()
|
Location |
AMQTx.getLocation()
|
protected Location |
AMQMessageStore.getLocation(MessageId messageId)
|
Location |
AMQMessageStore.getMark()
|
Location |
AMQPersistenceAdapter.writeCommand(DataStructure command,
boolean syncHint)
|
Location |
AMQPersistenceAdapter.writeCommand(DataStructure command,
boolean syncHint,
boolean forceSync)
|
Methods in org.apache.activemq.store.amq with parameters of type Location | |
---|---|
void |
AMQTransactionStore.acknowledge(AMQTopicMessageStore store,
JournalTopicAck ack,
Location location)
|
protected void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
MessageId messageId,
Location location,
java.lang.String clientId,
java.lang.String subscriptionName)
|
void |
AMQTx.add(AMQMessageStore store,
Message msg,
Location location)
|
AMQTx |
AMQTransactionStore.getTx(TransactionId txid,
Location location)
|
DataStructure |
AMQPersistenceAdapter.readCommand(Location location)
|
void |
AMQTransactionStore.removeMessage(AMQMessageStore store,
MessageAck ack,
Location location)
|
boolean |
AMQMessageStore.replayAddMessage(ConnectionContext context,
Message message,
Location location)
|
void |
AMQTxOperation.setLocation(Location location)
|
Constructors in org.apache.activemq.store.amq with parameters of type Location | |
---|---|
AMQTx(Location location)
|
|
AMQTxOperation(byte operationType,
ActiveMQDestination destination,
java.lang.Object data,
Location location)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |