Revision 946600

Jump to revision:
Author:	rajdavies
Date:	Thu May 20 12:02:10 2010 UTC (14 years, 5 months ago)
Changed paths:	43
Log Message:	fixes for https://issues.apache.org/activemq/browse/AMQ-2620 and https://issues.apache.org/activemq/browse/AMQ-2568

Changed paths

Path	Details
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Broker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFilter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/EmptyBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ErrorBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/MutableBrokerFilter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/AbortSlowConsumerStrategy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FixedSizedSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/LastImageSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/NoSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/QueryBasedSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SlowConsumerStrategy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/TimedSubscriptionRecoveryPolicy.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBPersistenceAdapter.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/SystemUsage.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/embedded/EmbeddedActiveMQ.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DuplexNetworkTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usage/MemoryUsageTest.java	modified , text changed