/[Apache-SVN]
ViewVC logotype

Revision 389941


Jump to revision: Previous Next
Author: chirino
Date: Thu Mar 30 00:36:21 2006 UTC (18 years, 6 months ago)
Changed paths: 27
Log Message:
- Since we now have per destination usage managers, I updated the MessageStore API so that each destination's store can be maded aware of the manager for that store. 
  Some stores like the journal hold messages around and use the usage manager to know when it should flush to disk.
- Moved alot of the message reference counting logic from the PrefetchSubscription up to it's subclasses since they all seem to do it just a slightly different way.
  I think it makes easier to see now how the usage manager is affected by operations.
- I fixed and verifed that the keepDurableSubsActive=true option actually works.  I think we should make this the default setting since it
  make recovery safer.  Once we have a better spooling implementation we can turn if off again.


Changed paths

Path Details
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java modified , text changed
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/jmx/ManagedTopicRegion.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.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/QueueBrowserSubscription.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.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/TopicRegion.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageManager.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/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/JDBCPersistenceAdapter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.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/QuickJournalMessageStore.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalPersistenceAdapter.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/KahaPersistentAdaptor.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/MemoryPersistenceAdapter.java modified , text changed
Directoryincubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/policy/StrictOrderDispatchPolicyTest.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26