| Package | Description |
|---|---|
| org.apache.activemq.store.kahadb | |
| org.apache.activemq.store.kahadb.scheduler |
| Modifier and Type | Method and Description |
|---|---|
JournalCommand<?> |
MultiKahaDBTransactionStore.load(Location location) |
JournalCommand<?> |
MessageDatabase.load(Location location)
Loads a previously stored JournalMessage
|
protected JournalCommand<?> |
AbstractKahaDBStore.load(Location location)
Loads a previously stored JournalMessage
|
| Modifier and Type | Method and Description |
|---|---|
void |
MultiKahaDBTransactionStore.process(JournalCommand<?> command) |
protected abstract void |
AbstractKahaDBStore.process(JournalCommand<?> command,
Location location)
Process a stored or recovered JournalCommand instance and update the DB Index with the
state changes that this command produces.
|
Location |
MessageDatabase.store(JournalCommand<?> data) |
Location |
AbstractKahaDBStore.store(JournalCommand<?> command)
Store a command in the Journal and process to update the Store index.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync)
Store a command in the Journal and process to update the Store index.
|
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before,
Runnable after) |
Location |
MessageDatabase.store(JournalCommand<?> data,
boolean sync,
org.apache.activemq.store.kahadb.MessageDatabase.IndexAware before,
Runnable after,
Runnable onJournalStoreComplete)
All updated are are funneled through this method.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync,
Runnable before,
Runnable after)
Store a command in the Journal and process to update the Store index.
|
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
boolean sync,
Runnable before,
Runnable after,
Runnable onJournalStoreComplete)
All updated are are funneled through this method.
|
Location |
MessageDatabase.store(JournalCommand<?> data,
Runnable onJournalStoreComplete) |
Location |
AbstractKahaDBStore.store(JournalCommand<?> command,
Runnable onJournalStoreComplete)
Store a command in the Journal and process to update the Store index.
|
ByteSequence |
MessageDatabase.toByteSequence(JournalCommand<?> data) |
protected ByteSequence |
AbstractKahaDBStore.toByteSequence(JournalCommand<?> data)
Creates a new ByteSequence that represents the marshaled form of the given Journal Command.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
JobSchedulerStoreImpl.doRecover(JournalCommand<?> data,
Location location,
Location inDoubtlocation)
Called during index recovery to rebuild the index from the last known good location.
|
protected void |
JobSchedulerStoreImpl.process(JournalCommand<?> data,
Location location)
Called during recovery to allow the store to rebuild from scratch.
|
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.