[hornetq-commits] JBoss hornetq SVN: r11677 - branches/Branch_2_2_AS7/src/main/org/hornetq/core/client/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Wed Nov 9 05:01:41 EST 2011
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)
More information about the hornetq-commits
mailing list