[jboss-cvs] JBoss Messaging SVN: r6913 - trunk/src/main/org/jboss/messaging/core/client/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2009-05-20 06:12:11 -0400 (Wed, 20 May 2009)
New Revision: 6913

Modified:
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java
   trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java
Log:
fixed hudson test

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java	2009-05-20 09:59:56 UTC (rev 6912)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java	2009-05-20 10:12:11 UTC (rev 6913)
@@ -58,7 +58,7 @@
 
    public static final String DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME = "org.jboss.messaging.core.client.impl.RoundRobinConnectionLoadBalancingPolicy";
 
-   public static final long DEFAULT_PING_PERIOD = 1000000;
+   public static final long DEFAULT_PING_PERIOD = 5000;
 
    // 5 minutes - normally this should be much higher than ping period, this allows clients to re-attach on live
    // or backup without fear of session having already been closed when connection times out.

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java	2009-05-20 09:59:56 UTC (rev 6912)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java	2009-05-20 10:12:11 UTC (rev 6913)
@@ -775,7 +775,7 @@
          for (ConnectionEntry entry : copy)
          {           
             try
-            {
+            {              
                entry.connection.destroy();
             }
             catch (Throwable ignore)
@@ -884,10 +884,10 @@
 
          conn.addFailureListener(new DelegatingFailureListener(conn.getID()));
 
+         connections.put(conn.getID(), new ConnectionEntry(conn, connector));         
+         
          conn.startPinger();
 
-         connections.put(conn.getID(), new ConnectionEntry(conn, connector));
-
          if (debug)
          {
             checkAddDebug(conn);