You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ce...@apache.org on 2013/05/07 22:29:45 UTC
svn commit: r1480059 - in /activemq/trunk/activemq-leveldb-store/src:
main/scala/org/apache/activemq/leveldb/replicated/
test/java/org/apache/activemq/leveldb/test/
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");