activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1235586 - in /activemq/activemq-apollo/trunk: apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/ apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/
Date Wed, 25 Jan 2012 01:09:11 GMT
Author: chirino
Date: Wed Jan 25 01:09:11 2012
New Revision: 1235586

URL: http://svn.apache.org/viewvc?rev=1235586&view=rev
Log:
The pure java LevelDB impl on windows still needs more validation

Modified:
    activemq/activemq-apollo/trunk/apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/StoreFunSuiteSupport.scala
    activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBClient.scala

Modified: activemq/activemq-apollo/trunk/apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/StoreFunSuiteSupport.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/StoreFunSuiteSupport.scala?rev=1235586&r1=1235585&r2=1235586&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/StoreFunSuiteSupport.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/test/scala/org/apache/activemq/apollo/broker/store/StoreFunSuiteSupport.scala
Wed Jan 25 01:09:11 2012
@@ -134,6 +134,17 @@ abstract class StoreFunSuiteSupport exte
     msg_keys
   }
 
+  test("add and list queues") {
+    val A = add_queue("A")
+    val B = add_queue("B")
+    val C = add_queue("C")
+
+    val seq:Seq[Long] = List(A,B,C).toSeq
+    expectCB(seq) { cb=>
+      store.list_queues(cb)
+    }
+  }
+
   test("export and import") {
     val A = add_queue("A")
     val msg_keys = populate(A, "message 1"::"message 2"::"message 3"::Nil)
@@ -189,17 +200,6 @@ abstract class StoreFunSuiteSupport exte
     }
   }
 
-  test("add and list queues") {
-    val A = add_queue("A")
-    val B = add_queue("B")
-    val C = add_queue("C")
-
-    val seq:Seq[Long] = List(A,B,C).toSeq
-    expectCB(seq) { cb=>
-      store.list_queues(cb)
-    }
-  }
-
   test("get queue status") {
     val A = add_queue("my queue name")
     populate(A, "message 1"::"message 2"::"message 3"::Nil)

Modified: activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBClient.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBClient.scala?rev=1235586&r1=1235585&r2=1235586&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBClient.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-leveldb/src/main/scala/org/apache/activemq/apollo/broker/store/leveldb/leveldb/LevelDBClient.scala
Wed Jan 25 01:09:11 2012
@@ -243,7 +243,7 @@ class LevelDBClient(store: LevelDBStore)
     }.headOption.getOrElse(throw new Exception("Could not load any of the index factory classes:
"+factory_names))
 
     if( factory.getClass.getName == "org.iq80.leveldb.impl.Iq80DBFactory") {
-      warn("Using the pure java LevelDB implementation which is still experimental.  Production
users should use the JNI based LevelDB implementation instead.")
+      warn("Using the pure java LevelDB implementation which is still experimental.  If the
JNI version is not available for your platform, please switch to the BDB store instead. http://activemq.apache.org/apollo/documentation/user-manual.html#BDB_Store")
     }
 
     sync = config.sync.getOrElse(true);



Mime
View raw message