Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixup failing LevelDB XA test. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1407018 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2012-11-08 11:25:49 +00:00
parent 7c9fec6e25
commit 1a2cbe7641
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
activemq-core/src/test/java/org/apache/activemq/leveldb/LevelDBStoreBrokerTest.java
View File

@ -1,5 +1,6 @@
package org.apache.activemq.leveldb; package org.apache.activemq.leveldb;
import junit.framework.Test;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.BrokerTest; import org.apache.activemq.broker.BrokerTest;
import org.apache.activemq.store.PersistenceAdapter; import org.apache.activemq.store.PersistenceAdapter;
@ -12,13 +13,13 @@ import java.io.IOException;
*/ */
public class LevelDBStoreBrokerTest extends BrokerTest { public class LevelDBStoreBrokerTest extends BrokerTest {
// def suite: Test = { public static Test suite() {
// return new TestSuite(classOf[LevelDBStoreBrokerTest]) return suite(LevelDBStoreBrokerTest.class);
// } }
//
// def main(args: Array[String]): Unit = { public static void main(String[] args) {
// junit.textui.TestRunner.run(suite) junit.textui.TestRunner.run(suite());
// } }
@Override @Override
protected BrokerService createBroker() throws Exception { protected BrokerService createBroker() throws Exception {

1
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
View File

@ -311,6 +311,7 @@ class LevelDBStore extends ServiceSupport with BrokerServiceAware with Persisten
if( prepared ) { if( prepared ) {
uow.dequeue(xacontainer_id, message.getMessageId) uow.dequeue(xacontainer_id, message.getMessageId)
} }
message.setMessageId(message.getMessageId.copy())
store.doAdd(uow, message, delay) store.doAdd(uow, message, delay)
} }