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

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; }