[hornetq-commits] JBoss hornetq SVN: r11565 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2011-10-20 03:09:29 -0400 (Thu, 20 Oct 2011)
New Revision: 11565

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
Log:
removed loop for annoncing backup

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-10-19 21:03:14 UTC (rev 11564)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java	2011-10-20 07:09:29 UTC (rev 11565)
@@ -470,33 +470,29 @@
       {
          public void run()
          {
-             while (true)
+             try
              {
-                 try
-                 {
-                    if (log.isDebugEnabled())
-                    {
-                       log.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
-                    }
-                    ClientSessionFactory backupSessionFactory = backupServerLocator.connect();
-                    if (backupSessionFactory != null)
-                    {
-                       backupSessionFactory.getConnection()
-                                           .getChannel(0, -1)
-                                           .send(new NodeAnnounceMessage(System.currentTimeMillis(),
-                                                                         nodeUUID.toString(),
-                                                                         true,
-                                                                         connector,
-                                                                         null));
-                       log.info("backup announced");
-                       break;
-                    }
-                 }
-                 catch (Exception e)
-                 {
-                    log.warn("Unable to announce backup, retrying", e);
-                 }
+                if (log.isDebugEnabled())
+                {
+                   log.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
+                }
+                ClientSessionFactory backupSessionFactory = backupServerLocator.connect();
+                if (backupSessionFactory != null)
+                {
+                   backupSessionFactory.getConnection()
+                                       .getChannel(0, -1)
+                                       .send(new NodeAnnounceMessage(System.currentTimeMillis(),
+                                                                     nodeUUID.toString(),
+                                                                     true,
+                                                                     connector,
+                                                                     null));
+                   log.info("backup announced");
+                }
              }
+             catch (Exception e)
+             {
+                log.warn("Unable to announce backup, retrying", e);
+             }
          }
       });
    }