/[Apache-SVN]
ViewVC logotype

Revision 1240162


Jump to revision: Previous Next
Author: gtully
Date: Fri Feb 3 13:43:36 2012 UTC (12 years, 8 months ago)
Changed paths: 9
Log Message:
https://issues.apache.org/jira/browse/AMQ-3695: Failover using a JDBC Message Store and Virtual Topic can result in a lost message if queue is empty. Problem is that an empty destination is not recorded, as there is no entry in the messages table. Fix is to make use of the ack table, in the same way a for durable subs. For destinations that match the virtual topic filter, an entry out of priority range is added to the ack table. the startup destination query now unions over the ack and messages table

Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.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/JDBCMessageStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.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/DefaultJDBCAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/jdbc/JDBCNetworkBrokerDetachTest.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26