Uses of Interface
org.apache.activemq.store.kahadb.JournalCommand

Packages that use JournalCommand

Package	Description
org.apache.activemq.store.kahadb
org.apache.activemq.store.kahadb.data
org.apache.activemq.store.kahadb.scheduler

Uses of JournalCommand in org.apache.activemq.store.kahadb

Methods in org.apache.activemq.store.kahadb that return JournalCommand

Modifier and Type	Method	Description
protected JournalCommand<?>	AbstractKahaDBStore.load(Location location)	Loads a previously stored JournalMessage
JournalCommand<?>	MessageDatabase.load(Location location)	Loads a previously stored JournalMessage
JournalCommand<?>	MultiKahaDBTransactionStore.load(Location location)

Methods in org.apache.activemq.store.kahadb with parameters of type JournalCommand

Modifier and Type	Method	Description
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.
void	MultiKahaDBTransactionStore.process(Location location, JournalCommand<?> command)
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	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	AbstractKahaDBStore.store(JournalCommand<?> command, Runnable onJournalStoreComplete)	Store a command in the Journal and process to update the Store index.
Location	MessageDatabase.store(JournalCommand<?> data)
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	MessageDatabase.store(JournalCommand<?> data, Runnable onJournalStoreComplete)
protected ByteSequence	AbstractKahaDBStore.toByteSequence(JournalCommand<?> data)	Creates a new ByteSequence that represents the marshaled form of the given Journal Command.
ByteSequence	MessageDatabase.toByteSequence(JournalCommand<?> data)

Uses of JournalCommand in org.apache.activemq.store.kahadb.data

Classes in org.apache.activemq.store.kahadb.data that implement JournalCommand

Modifier and Type	Class	Description
class	KahaAckMessageFileMapCommand
class	KahaAddMessageCommand
class	KahaAddScheduledJobCommand
class	KahaCommitCommand
class	KahaDestroySchedulerCommand
class	KahaPrepareCommand
class	KahaProducerAuditCommand
class	KahaRemoveDestinationCommand
class	KahaRemoveMessageCommand
class	KahaRemoveScheduledJobCommand
class	KahaRemoveScheduledJobsCommand
class	KahaRescheduleJobCommand
class	KahaRewrittenDataFileCommand
class	KahaRollbackCommand
class	KahaSubscriptionCommand
class	KahaTraceCommand
class	KahaUpdateMessageCommand

Uses of JournalCommand in org.apache.activemq.store.kahadb.scheduler

Methods in org.apache.activemq.store.kahadb.scheduler with parameters of type JournalCommand

Modifier and Type	Method	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.