You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by ch...@apache.org on 2013/07/25 15:40:59 UTC

svn commit: r1506965 - /activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala

Author: chirino
Date: Thu Jul 25 13:40:59 2013
New Revision: 1506965

URL: http://svn.apache.org/r1506965
Log:
Warn when there are too many replication nodes attached.

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

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=1506965&r1=1506964&r2=1506965&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 Thu Jul 25 13:40:59 2013
@@ -96,6 +96,10 @@ class MasterElector(store: ElectingLevel
             info("Not enough cluster members connected to elect a new master.")
           case Some(members) =>
 
+            if (members.size > store.replicas) {
+              warn("Too many cluster members are connected.  Expected at most "+store.replicas+
+                      " members but there are "+members.size+" connected.")
+            }
             if (members.size < store.clusterSizeQuorum) {
               info("Not enough cluster members connected to elect a master.")
               elected = null