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

fixed some small code mistypes in replicated leveldb. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1480059 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Christian Posta 2013-05-07 20:29:45 +00:00
parent d7aaca5034
commit ee97df7422
3 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -126,7 +126,6 @@ class ElectingLevelDBStore extends ProxyLevelDBStore {
var zk_client: ZKClient = _
var zk_group: Group = _
var master_elector: MasterElector = _
var position: Long = -1L

4
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
View File

@ -54,7 +54,7 @@ class MasterElector(store: ElectingLevelDBStore) extends ClusteredSingleton[Leve
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: ElectingLevelDBStore) extends ClusteredSingleton[Leve
rc
}
object changle_listener extends ChangeListener {
object change_listener extends ChangeListener {
def connected = changed
def disconnected = changed

2
activemq-leveldb-store/src/test/java/org/apache/activemq/leveldb/test/ElectingLevelDBStoreTest.java
View File

@ -214,7 +214,7 @@ public class ElectingLevelDBStoreTest extends TestCase {
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");