/[Apache-SVN]
ViewVC logotype

Revision 1100208


Jump to revision: Previous Next
Author: gtully
Date: Fri May 6 13:27:49 2011 UTC (13 years, 5 months ago)
Changed paths: 21
Log Message:
https://issues.apache.org/jira/browse/AMQ-3305 - Implement "exactly once" delivery with kahaDB and XA in the event of a failure post prepare.
Fixed up transaction broker recovery processing and kahadb store such that pending recovered
messages and acks wait for and respect the eventual xa transction outcome. Essentially
implementing exactly once delivery semantics on failure. Updated the camel jms to jdbc
test route to validate correct failure recovery processing with geronimo, test pulls in
xa wrappers from jencks and openejb such that NamedXAResources are registered with geronimo.
Additional unit tests added.

Changed paths

Path Details
Directoryactivemq/trunk/activemq-camel/pom.xml modified , text changed
Directoryactivemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java modified , text changed
Directoryactivemq/trunk/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml modified , text changed
Directoryactivemq/trunk/activemq-core/pom.xml modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/XATransactionId.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/transaction/XATransaction.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.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/XARecoveryBrokerTest.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/util/SocketProxy.java modified , text changed
Directoryactivemq/trunk/activemq-pool/src/main/java/org/apache/activemq/pool/ActiveMQResourceManager.java modified , text changed
Directoryactivemq/trunk/activemq-pool/src/main/java/org/apache/activemq/pool/PooledSession.java modified , text changed
Directoryactivemq/trunk/pom.xml modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26