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

[do-not-reply at jboss.org]

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)
             {