[jboss-cvs] JBoss Messaging SVN: r7578 - in trunk/src/main/org/jboss/messaging/core: remoting/server/impl and 1 other directory.

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

Author: ataylor
Date: 2009-07-16 08:55:44 -0400 (Thu, 16 Jul 2009)
New Revision: 7578

Modified:
   trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java
   trunk/src/main/org/jboss/messaging/core/remoting/server/impl/RemotingServiceImpl.java
Log:
changed piongers to run after fixed delay

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java	2009-07-16 09:38:21 UTC (rev 7577)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ConnectionManagerImpl.java	2009-07-16 12:55:44 UTC (rev 7578)
@@ -969,7 +969,7 @@
 
          if (clientFailureCheckPeriod != -1)
          {
-            Future<?> pingerFuture = scheduledThreadPool.scheduleAtFixedRate(pinger,
+            Future<?> pingerFuture = scheduledThreadPool.scheduleWithFixedDelay(pinger,
                                                                              clientFailureCheckPeriod,
                                                                              clientFailureCheckPeriod,
                                                                              TimeUnit.MILLISECONDS);

Modified: trunk/src/main/org/jboss/messaging/core/remoting/server/impl/RemotingServiceImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/server/impl/RemotingServiceImpl.java	2009-07-16 09:38:21 UTC (rev 7577)
+++ trunk/src/main/org/jboss/messaging/core/remoting/server/impl/RemotingServiceImpl.java	2009-07-16 12:55:44 UTC (rev 7578)
@@ -381,7 +381,7 @@
 
       Pinger pingRunnable = new Pinger(conn, connectionTTLToUse, null, new FailedConnectionAction(conn), System.currentTimeMillis());
 
-      Future<?> pingFuture = scheduledThreadPool.scheduleAtFixedRate(pingRunnable, 0, pingPeriod, TimeUnit.MILLISECONDS);
+      Future<?> pingFuture = scheduledThreadPool.scheduleWithFixedDelay(pingRunnable, 0, pingPeriod, TimeUnit.MILLISECONDS);
 
       pingRunnable.setFuture(pingFuture);