[hornetq-commits] JBoss hornetq SVN: r11644 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-11-02 17:04:13 -0400 (Wed, 02 Nov 2011)
New Revision: 11644

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java
Log:
Just adding some debug just in case

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java	2011-11-02 20:51:25 UTC (rev 11643)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java	2011-11-02 21:04:13 UTC (rev 11644)
@@ -39,6 +39,7 @@
 import org.hornetq.core.protocol.core.impl.wireformat.SubscribeClusterTopologyUpdatesMessageV2;
 import org.hornetq.core.remoting.CloseListener;
 import org.hornetq.core.server.HornetQServer;
+import org.hornetq.core.server.cluster.ClusterConnection;
 import org.hornetq.spi.core.protocol.ConnectionEntry;
 import org.hornetq.spi.core.protocol.ProtocolManager;
 import org.hornetq.spi.core.protocol.RemotingConnection;
@@ -208,8 +209,23 @@
                {
                   log.trace("Server " + server + " receiving nodeUp from NodeID=" + msg.getNodeID() + ", pair=" + pair);
                }
-
-               acceptorUsed.getClusterConnection().nodeAnnounced(msg.getCurrentEventID(), msg.getNodeID(), pair, msg.isBackup());
+               
+               if (acceptorUsed != null)
+               {
+                  ClusterConnection clusterConn = acceptorUsed.getClusterConnection();
+                  if (clusterConn != null)
+                  {
+                     clusterConn.nodeAnnounced(msg.getCurrentEventID(), msg.getNodeID(), pair, msg.isBackup());
+                  }
+                  else
+                  {
+                     log.debug("Cluster connection is null on acceptor = " + acceptorUsed);
+                  }
+               }
+               else
+               {
+                  log.debug("there is no acceptor used configured at the CoreProtocolManager " + this);
+               }
             }
          }
       });