activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1506965 - /activemq/trunk/activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/replicated/MasterElector.scala
Date Thu, 25 Jul 2013 13:40:59 GMT
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



Mime
View raw message