[hornetq-commits] JBoss hornetq SVN: r11644 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/protocol/core/impl.
Author: clebert.suconic(a)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);
+ }
}
}
});