[hornetq-commits] JBoss hornetq SVN: r10930 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl.

Author: borges Date: 2011-07-06 06:20:45 -0400 (Wed, 06 Jul 2011) New Revision: 10930 Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java Log: Give a shorter name to the new method (it is private anyway) Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java =================================================================== --- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java 2011-07-06 04:55:20 UTC (rev 10929) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/CoreProtocolManager.java 2011-07-06 10:20:45 UTC (rev 10930) @@ -143,8 +143,7 @@ { NodeAnnounceMessage msg = (NodeAnnounceMessage)packet; - server.getClusterManager().notifyNodeUp(msg.getNodeID(), - getPairForNotification(msg.getConnector(), msg.isBackup()), + server.getClusterManager().notifyNodeUp(msg.getNodeID(), getPair(msg.getConnector(), msg.isBackup()), false, true); } else if (packet.getType() == PacketImpl.HA_BACKUP_REGISTRATION) @@ -162,14 +161,12 @@ e.printStackTrace(); throw new RuntimeException(e); } - server.getClusterManager().notifyNodeUp(msg.getNodeID(), - getPairForNotification(msg.getConnector(), true), true, true); + server.getClusterManager().notifyNodeUp(msg.getNodeID(), getPair(msg.getConnector(), true), true, true); } } - private - Pair<TransportConfiguration, TransportConfiguration> - getPairForNotification(TransportConfiguration conn, boolean isBackup) + private Pair<TransportConfiguration, TransportConfiguration> getPair(TransportConfiguration conn, + boolean isBackup) { if (isBackup) {