[hornetq-commits] JBoss hornetq SVN: r11652 - in trunk/hornetq-core/src/main/java/org/hornetq/core: server and 1 other directories.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-11-03 09:41:25 -0400 (Thu, 03 Nov 2011)
New Revision: 11652

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ServerLocatorImpl.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/server/HornetQServer.java
   trunk/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
Delete unused methods

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2011-11-03 13:41:08 UTC (rev 11651)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2011-11-03 13:41:25 UTC (rev 11652)
@@ -538,11 +538,6 @@
       stopPingingAfterOne = true;
    }
 
-   public void resumePinging()
-   {
-      stopPingingAfterOne = false;
-   }
-
    // Protected
    // ------------------------------------------------------------------------------------
 

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ServerLocatorImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-11-03 13:41:08 UTC (rev 11651)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/client/impl/ServerLocatorImpl.java	2011-11-03 13:41:25 UTC (rev 11652)
@@ -766,7 +766,6 @@
                catch (InterruptedException ignore)
                {
                }
-
             }
 
             if (System.currentTimeMillis() > timeout && !receivedTopology && isInitialized())

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/server/HornetQServer.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/server/HornetQServer.java	2011-11-03 13:41:08 UTC (rev 11651)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/server/HornetQServer.java	2011-11-03 13:41:25 UTC (rev 11652)
@@ -15,7 +15,6 @@
 
 import java.util.List;
 import java.util.Set;
-import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ScheduledExecutorService;
 
 import javax.management.MBeanServer;
@@ -160,8 +159,6 @@
 
    ScheduledExecutorService getScheduledPool();
 
-   ExecutorService getThreadPool();
-
    ExecutorFactory getExecutorFactory();
 
    void setGroupingHandler(GroupingHandler groupingHandler);

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-11-03 13:41:08 UTC (rev 11651)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-11-03 13:41:25 UTC (rev 11652)
@@ -378,12 +378,8 @@
 
             started = true;
 
-            HornetQServerImpl.log.info("HornetQ Server version " + getVersion().getFullVersion() +
-                                       " [" +
-                                       nodeManager.getNodeId() +
-                                       "]" +
-                                       (this.identity != null ? " (" + identity : ")") +
-                                       " started");
+            HornetQServerImpl.log.info("HornetQ Server version " + getVersion().getFullVersion() + " [" +
+                     nodeManager.getNodeId() + "]" + (this.identity != null ? " (" + identity + ")" : "") + " started");
          }
 
          // The activation on fail-back may change the value of isBackup, for that reason we are not using else here
@@ -704,11 +700,6 @@
       return scheduledPool;
    }
 
-   public ExecutorService getThreadPool()
-   {
-      return threadPool;
-   }
-
    public Configuration getConfiguration()
    {
       return configuration;