/[Apache-SVN]
ViewVC logotype

Revision 581053


Jump to revision: Previous Next
Author: chirino
Date: Mon Oct 1 20:02:18 2007 UTC (17 years, 1 month ago)
Changed paths: 19
Log Message:
Fix for AMQ-1095:
 - Added contributed test cases
 - We now filter out non-matching messages as they are loaded into the TopicStorePrefetch
 - Changed the TopicStorePrefetch and StoreDurableSubscriberCursor so that they don't depend
   on the pending message counter since some stores cannot give an accurate count for it.



Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorSupport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/ added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/ActiveMQTestCase.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/MessageSelectorTest.java added
Directoryactivemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/ added
Directoryactivemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/amq1095/ added
Directoryactivemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/amq1095/activemq.xml added

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26