/[Apache-SVN]
ViewVC logotype

Revision 492373


Jump to revision: Previous Next
Author: chirino
Date: Thu Jan 4 00:57:03 2007 UTC (17 years, 9 months ago)
Changed paths: 38
Log Message:
- Big refactor of the QuickJournal:
  - Move it to it's own package org.apache.activemq.store.quick
  - Brought in all the latest JournalPersistenceAdaptor enhancements
  - It now uses the AsyncDataManager as the Journal implemenation which has better read performance
  - Instead of forcing all PersistenceAdaptors to support external references, we now move all the message reference methods to a new set of interface class (MesageReferenceAdaptor)
  - Enhanced a few Kaha container classes so that they take advantage of Generics
  - Added a Kaha based MesageReferenceAdaptor impementation
  - Strategy for deleting old journal log files is now in place so that disk space can be reclaimed.


Changed paths

Path Details
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ListContainer.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Marshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StringMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/Location.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileReader.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/SyncDataFileWriter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/DefaultPersistenceAdapterFactory.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/MessageRecoveryListener.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/MessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/PersistenceAdapter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyTopicMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCTopicMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalMessageData.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalMessageStore.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalPersistenceAdapter.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTopicMessageStore.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTransactionStore.java deleted
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/CommandMarshaller.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicSub.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LRUCache.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26