activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cepo...@apache.org
Subject svn commit: r1480059 - in /activemq/trunk/activemq-leveldb-store/src: main/scala/org/apache/activemq/leveldb/replicated/ test/java/org/apache/activemq/leveldb/test/
Date Tue, 07 May 2013 20:29:45 GMT
Author: ceposta
Date: Tue May  7 20:29:45 2013
New Revision: 1480059

URL: http://svn.apache.org/r1480059
Log:
fixed some small code mistypes in replicated leveldb.

Modified:
    activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
    activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
    activemq/trunk/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java

Modified: activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala?rev=1480059&r1=1480058&r2=1480059&view=diff
==============================================================================
--- activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
(original)
+++ activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/ElectingLevelDBStore.scala
Tue May  7 20:29:45 2013
@@ -126,7 +126,6 @@ class ElectingLevelDBStore extends Proxy
 
   var zk_client: ZKClient = _
   var zk_group: Group = _
-  var master_elector: MasterElector = _
 
   var position: Long = -1L
 

Modified: activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala?rev=1480059&r1=1480058&r2=1480059&view=diff
==============================================================================
--- activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
(original)
+++ activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
Tue May  7 20:29:45 2013
@@ -54,7 +54,7 @@ class MasterElector(store: ElectingLevel
   def join: Unit = this.synchronized {
     last_state = create_state
     join(last_state)
-    add(changle_listener)
+    add(change_listener)
   }
 
   def elector  = this
@@ -76,7 +76,7 @@ class MasterElector(store: ElectingLevel
     rc
   }
 
-  object changle_listener extends ChangeListener {
+  object change_listener extends ChangeListener {
 
     def connected = changed
     def disconnected = changed

Modified: activemq/trunk/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java?rev=1480059&r1=1480058&r2=1480059&view=diff
==============================================================================
--- activemq/trunk/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java
(original)
+++ activemq/trunk/activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java
Tue May  7 20:29:45 2013
@@ -214,7 +214,7 @@ public class ElectingLevelDBStoreTest ex
     private ElectingLevelDBStore createStoreNode() {
         ElectingLevelDBStore store = new ElectingLevelDBStore();
         store.setSecurityToken("foo");
-        store.setLogSize(1023 * 200);
+        store.setLogSize(1024 * 200);
         store.setReplicas(2);
         store.setZkAddress("localhost:" + connector.getLocalPort());
         store.setZkPath("/broker-stores");



Mime
View raw message