/[Apache-SVN]

Revision 753214

Jump to revision:
Author:	gtully
Date:	Fri Mar 13 11:59:08 2009 UTC (15 years, 7 months ago)
Changed paths:	10
Log Message:	resolve AMQ-2102\|https://issues.apache.org/activemq/browse/AMQ-2102 - refactor message dispatch on slave to take account of subscription choice on the master, this ensures slave is in sync w.r.t outstanding acks. processDispatchNotification imoplemented by Queue type destinations which delegates to subscription after doing a dispatch, test demonstrates slve out of sync errors

Changed paths

Path	Details
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterBroker.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.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/Destination.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.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/QueueRegion.java	modified , text changed
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/MasterSlaveTempQueueMemoryTest.java	modified , text changed
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26