Author: ataylor Date: 2011-11-09 05:01:40 -0500 (Wed, 09 Nov 2011) New Revision: 11677 Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java Log: updated debug and close factory on failed connect Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java =================================================================== --- branches/Branch_2_2_AS7/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java 2011-11-08 20:45:22 UTC (rev 11676) +++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/client/impl/ServerLocatorImpl.java 2011-11-09 10:01:40 UTC (rev 11677) @@ -609,10 +609,10 @@ public ClientSessionFactory createSessionFactory(String nodeID) throws Exception { - log.info(topology.describe("full topology")); + log.trace(topology.describe("full topology")); TopologyMember topologyMember = topology.getMember(nodeID); - log.info("Creating connection factory towards " + nodeID + " = " + topologyMember); + log.trace("Creating connection factory towards " + nodeID + " = " + topologyMember); if (topologyMember == null) { @@ -675,6 +675,7 @@ private void removeFromConnecting(ClientSessionFactoryInternal factory) { connectingFactories.remove(factory); + factory.close(); } private void addToConnecting(ClientSessionFactoryInternal factory)