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

Adding more debug info to help trouble shoot election issues with leveldb replication elections.

This commit is contained in:
Hiram Chirino 2013-10-02 10:45:47 -04:00
parent 887ac0ba49
commit 8804341c19
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -181,7 +181,9 @@ class ElectingLevelDBStore extends ProxyLevelDBStore {
val zk_group = ZooKeeperGroupFactory.create(zk_client, zkPath) val zk_group = ZooKeeperGroupFactory.create(zk_client, zkPath)
val master_elector = new MasterElector(this) val master_elector = new MasterElector(this)
debug("Starting ZooKeeper group monitor")
master_elector.start(zk_group) master_elector.start(zk_group)
debug("Joining ZooKeeper group")
master_elector.join master_elector.join
this.setUseLock(true) this.setUseLock(true)

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

@ -90,6 +90,8 @@ class MasterElector(store: ElectingLevelDBStore) extends ClusteredSingleton[Leve
} }
def changed:Unit = elector.synchronized { def changed:Unit = elector.synchronized {
debug("ZooKeeper group changed: %s", members)
// info(eid+" cluster state changed: "+members) // info(eid+" cluster state changed: "+members)
if (isMaster) { if (isMaster) {
// We are the master elector, we will choose which node will startup the MasterLevelDBStore // We are the master elector, we will choose which node will startup the MasterLevelDBStore