Package | Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
Location |
Entry.getLocation() |
Modifier and Type | Method and Description |
---|---|
void |
Entry.setLocation(Location location) |
Modifier and Type | Field and Description |
---|---|
Location |
MessageAckWithLocation.location |
Constructor and Description |
---|
MessageAckWithLocation(MessageAck ack,
Location location) |
Modifier and Type | Field and Description |
---|---|
protected Location |
AsyncDataManager.mark |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Location> |
AsyncDataManager.lastAppendLocation |
Modifier and Type | Method and Description |
---|---|
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(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,
Runnable onComplete) |
Modifier and Type | Method and Description |
---|---|
int |
Location.compareTo(Location o) |
long |
AsyncDataManager.getDiskSizeUntil(Location startPosition) |
Location |
AsyncDataManager.getNextLocation(DataFile dataFile,
Location lastLocation,
boolean thisFileOnly) |
Location |
AsyncDataManager.getNextLocation(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) |
Constructor and Description |
---|
JournalFacade.RecordLocationFacade(Location location) |
Modifier and Type | Field and Description |
---|---|
protected Location |
AMQMessageStore.lastLocation |
protected Location |
AMQMessageStore.lastWrittenLocation |
Modifier and Type | Field and Description |
---|---|
protected Set<Location> |
AMQMessageStore.inFlightTxLocations |
Modifier and Type | Method and Description |
---|---|
Location |
AMQTransactionStore.checkpoint() |
protected Location |
AMQMessageStore.doAsyncWrite() |
Location |
AMQTx.getLocation() |
Location |
AMQTxOperation.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) |
Modifier and Type | Method and Description |
---|---|
void |
AMQTransactionStore.acknowledge(AMQTopicMessageStore store,
JournalTopicAck ack,
Location location) |
protected void |
AMQTopicMessageStore.acknowledge(ConnectionContext context,
MessageId messageId,
Location location,
String clientId,
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) |
Constructor and Description |
---|
AMQTx(Location location) |
AMQTxOperation(byte operationType,
ActiveMQDestination destination,
Object data,
Location location) |
Copyright © 2005–2017. All rights reserved.