[hornetq-commits] JBoss hornetq SVN: r7871 - trunk/src/main/org/hornetq/core/transaction/impl.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2009-08-21 11:15:32 -0400 (Fri, 21 Aug 2009)
New Revision: 7871

Modified:
   trunk/src/main/org/hornetq/core/transaction/impl/ResourceManagerImpl.java
Log:
removed tx timeout - see https://jira.jboss.org/jira/browse/HORNETQ-106

Modified: trunk/src/main/org/hornetq/core/transaction/impl/ResourceManagerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/transaction/impl/ResourceManagerImpl.java	2009-08-21 15:15:06 UTC (rev 7870)
+++ trunk/src/main/org/hornetq/core/transaction/impl/ResourceManagerImpl.java	2009-08-21 15:15:32 UTC (rev 7871)
@@ -50,11 +50,11 @@
 
    private boolean started = false;
 
-   private TxTimeoutHandler task;
+   //private TxTimeoutHandler task;
 
    private final long txTimeoutScanPeriod;
 
-   private final ScheduledExecutorService scheduledThreadPool;
+   //private final ScheduledExecutorService scheduledThreadPool;
 
    public ResourceManagerImpl(final int defaultTimeoutSeconds, 
                               final long txTimeoutScanPeriod, 
@@ -63,7 +63,7 @@
       this.defaultTimeoutSeconds = defaultTimeoutSeconds;
       this.timeoutSeconds = defaultTimeoutSeconds;
       this.txTimeoutScanPeriod = txTimeoutScanPeriod;
-      this.scheduledThreadPool = scheduledThreadPool;
+     // this.scheduledThreadPool = scheduledThreadPool;
    }
 
    // HornetQComponent implementation
@@ -74,10 +74,10 @@
       {
          return;
       }
-      
-      task = new TxTimeoutHandler();
+      //todo - https://jira.jboss.org/jira/browse/HORNETQ-106
+      /*task = new TxTimeoutHandler();
       Future<?> future = scheduledThreadPool.scheduleAtFixedRate(task, txTimeoutScanPeriod, txTimeoutScanPeriod, TimeUnit.MILLISECONDS);
-      task.setFuture(future);
+      task.setFuture(future);*/
       
       started = true;
    }
@@ -88,10 +88,10 @@
       {
          return;
       }
-      if (task != null)
+      /*if (task != null)
       {
          task.close();
-      }
+      }*/
 
       started = false;
    }