A B C D G H I J O R S W

A

addMessage(ActiveMQMessage) - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing.

B

beginTransaction() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

C

checkpoint() - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
checkpoint() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
When we checkpoint we move all the journaled data to long term storage.
commitTransaction() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createJournal() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createPreparedTransactionStore() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createQueueMessageStore(String) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createRecoveryFailedException(Exception) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createTopicMessageStore(String) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createWriteException(Packet, Exception) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
createWriteException(String, Exception) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

D

DEFAULT_JOURNAL_TYPE - Static variable in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

G

getClockDaemon() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
getDirectory() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
getInitialDestinations() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
getJournalType() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
getLongTermPersistence() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
getLongTermStore() - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
getMessage(MessageIdentity) - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
getWireFormat() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

H

HOWL_JOURNAL_TYPE - Static variable in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

I

isSync() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

J

JournalMessageStore - class org.codehaus.activemq.store.journal.JournalMessageStore.
A MessageStore that uses a Journal to store it's messages.
JournalMessageStore(JournalPersistenceAdapter, MessageStore, String, boolean) - Constructor for class org.codehaus.activemq.store.journal.JournalMessageStore
 
JournalPersistenceAdapter - class org.codehaus.activemq.store.journal.JournalPersistenceAdapter.
An implementation of PersistenceAdapter designed for use with a Journal and then checkpointing asynchronously on a timeout with some other long term persistent storage.
JournalPersistenceAdapter() - Constructor for class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
JournalPersistenceAdapter(File, PersistenceAdapter, DefaultWireFormat) - Constructor for class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

O

org.codehaus.activemq.store.journal - package org.codehaus.activemq.store.journal
Message persistence using a high performance transaction log via the Journal interface.
overflowNotification(RecordLocation) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
The Journal give us a call back so that we can move old data out of the journal.

R

readPacket(RecordLocation) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
recover(QueueMessageContainer) - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
Replays the checkpointStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated.
removeAllMessages() - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
removeMessage(MessageIdentity, MessageAck) - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
rollbackTransaction() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

S

setCacheMessageStore(CacheMessageStore) - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
setClockDaemon(ClockDaemon) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
setDirectory(File) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
setJournalType(String) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
setLongTermPersistence(PersistenceAdapter) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
setSync(boolean) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
setWireFormat(WireFormat) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
start() - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
start() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
stop() - Method in class org.codehaus.activemq.store.journal.JournalMessageStore
 
stop() - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

W

writeCommand(String, boolean) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 
writePacket(String, Packet, boolean) - Method in class org.codehaus.activemq.store.journal.JournalPersistenceAdapter
 

A B C D G H I J O R S W

Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.