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

https://issues.apache.org/jira/browse/AMQ-5506 - fix typo in leveldb attribute ZkSessionTmeout - now with the i, store.setZkSessionTimeout

This commit is contained in:
gtully 2015-01-05 20:49:26 +00:00
parent 5ebe71cec9
commit 4d8489ba38
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-leveldb-store/src/main/java/org/apache/activemq/leveldb/replicated/ReplicatedLevelDBStoreViewMBean.java
View File

@ -34,7 +34,7 @@ public interface ReplicatedLevelDBStoreViewMBean {
@MBeanInfo("The path in ZooKeeper to hold master elections.")
String getZkPath();
@MBeanInfo("The ZooKeeper session timeout.")
String getZkSessionTmeout();
String getZkSessionTimeout();
@MBeanInfo("The address and port the master will bind for the replication protocol.")
String getBind();
@MBeanInfo("The number of replication nodes that will be part of the replication cluster.")

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

@ -69,7 +69,7 @@ class ElectingLevelDBStore extends ProxyLevelDBStore {
@BeanProperty
var zkPath = "/default"
@BeanProperty
var zkSessionTmeout = "2s"
var zkSessionTimeout = "2s"
var brokerName: String = _
@ -181,7 +181,7 @@ class ElectingLevelDBStore extends ProxyLevelDBStore {
log.close
}
zk_client = new ZKClient(zkAddress, Timespan.parse(zkSessionTmeout), null)
zk_client = new ZKClient(zkAddress, Timespan.parse(zkSessionTimeout), null)
if( zkPassword!=null ) {
zk_client.setPassword(zkPassword)
}
@ -415,7 +415,7 @@ class ReplicatedLevelDBStoreView(val store:ElectingLevelDBStore) extends Replica
def getZkAddress = zkAddress
def getZkPath = zkPath
def getZkSessionTmeout = zkSessionTmeout
def getZkSessionTimeout = zkSessionTimeout
def getBind = bind
def getReplicas = replicas

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

@ -447,7 +447,7 @@ public class ReplicatedLevelDBBrokerTest extends ZooKeeperTestSupport {
store.setContainer(id);
store.setReplicas(3);
store.setZkAddress("localhost:" + connector.getLocalPort());
store.setZkSessionTmeout("15s");
store.setZkSessionTimeout("15s");
store.setHostname("localhost");
store.setBind("tcp://0.0.0.0:0");
return store;