/[Apache-SVN]
ViewVC logotype

Revision 1345202


Jump to revision: Previous Next
Author: gtully
Date: Fri Jun 1 14:32:50 2012 UTC (12 years, 5 months ago)
Changed paths: 20
Log Message:
https://issues.apache.org/jira/browse/AMQ-3872 - Implement "exactly once" delivery with JDBC and XA in the event of a failure post prepare. jdbc xa is not a runner due to single table and update locks. implemention adds xid column to messages and acks table. a non null value indicated a prepared add/ack, so the insert is done on prepare. the result of the transaction outcome requires a row level update

Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ConnectionContext.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/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/Topic.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageId.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/TopicMessageStore.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/JdbcMemoryTransactionStore.java added
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/BlobJDBCAdapter.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/jdbc/adapter/OracleBlobJDBCAdapter.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTransactionStore.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/JdbcXARecoveryBrokerTest.java added
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26