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;