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); + } } } });