/[Apache-SVN]
ViewVC logotype

Revision 563194


Jump to revision: Previous Next
Author: chirino
Date: Mon Aug 6 17:07:55 2007 UTC (17 years, 2 months ago)
Changed paths: 29
Log Message:
Fix for AMQ-1356 : Durable Subscriptions do not work with Wildcards after broker is restarted.
 - Added a RecoveryBrokerTest.testWildCardSubscriptionPreservedOnRestart() test case that was showing
   that that wildcards did not work with DurableSubscriptions
 - Fix the TransactedTopicMasterSlaveTest so that setDeleteAllMessagesOnStartup() takes effect (had to be done before the connectors are added.
 - Change the MessageStore interface so that subscriptions are created using the data in the SubscriptionInfo class
 - Added a subscribedDestination field to the SubscriptionInfo so that the original wildcard subscrption can be remembered
 - The KahaReference store now deletes it's State store too when deleteAllMessages() is called
 - Fixed KahaPersistenceAdapter.getDestinations() so that it actually returns all the destinations.
 - We now recover all the topics eagerly when the topic region is started.



Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.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/Topic.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/SubscriptionInfo.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/SubscriptionInfoMarshaller.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyTopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicReferenceStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCTopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/Statements.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/AxionJDBCAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicMessageStore.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/ft/TransactedTopicMasterSlaveTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/v3/SubscriptionInfoTest.java modified , text changed
Directoryactivemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPATopicMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPATopicReferenceStore.java modified , text changed
Directoryactivemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/model/StoredSubscription.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26