[jboss-cvs] JBossAS SVN: r84354 - projects/ejb3/trunk/async-impl/src/test/java/org/jboss/ejb3/async/impl/test/cancel.

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

Author: ALRubinger
Date: 2009-02-18 00:14:40 -0500 (Wed, 18 Feb 2009)
New Revision: 84354

Modified:
   projects/ejb3/trunk/async-impl/src/test/java/org/jboss/ejb3/async/impl/test/cancel/PausableBlockingQueue.java
Log:
[EJBTHREE-1721] Get rid of redundant state variable

Modified: projects/ejb3/trunk/async-impl/src/test/java/org/jboss/ejb3/async/impl/test/cancel/PausableBlockingQueue.java
===================================================================
--- projects/ejb3/trunk/async-impl/src/test/java/org/jboss/ejb3/async/impl/test/cancel/PausableBlockingQueue.java	2009-02-18 05:11:57 UTC (rev 84353)
+++ projects/ejb3/trunk/async-impl/src/test/java/org/jboss/ejb3/async/impl/test/cancel/PausableBlockingQueue.java	2009-02-18 05:14:40 UTC (rev 84354)
@@ -26,7 +26,6 @@
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.jboss.logging.Logger;
 
@@ -55,8 +54,6 @@
    // Instance Members ---------------------------------------------------------------||
    // --------------------------------------------------------------------------------||
 
-   private final AtomicBoolean active = new AtomicBoolean(false);
-
    private final BlockingQueue<E> delegate;
 
    private final BlockingQueue<E> backlogQueue;
@@ -79,7 +76,6 @@
 
    public PausableBlockingQueue(boolean active)
    {
-      this.active.set(active);
       this.delegate = new ArrayBlockingQueue<E>(10);
       this.backlogQueue = new ArrayBlockingQueue<E>(10);
       this.currentQueue = active ? this.delegate : this.backlogQueue;
@@ -91,7 +87,7 @@
 
    public boolean isActive()
    {
-      return this.active.get();
+      return this.currentQueue == this.delegate ? true : false;
    }
 
    public void pause()
@@ -105,7 +101,6 @@
       // Atomic
       synchronized (this.currentQueue)
       {
-         this.active.set(false);
          this.currentQueue = this.backlogQueue;
          log.info(this + ": Paused");
       }
@@ -122,9 +117,6 @@
       // Atomic
       synchronized (this.currentQueue)
       {
-         // Set active
-         this.active.set(true);
-
          // Drain to the delegate from the backlog
          this.backlogQueue.drainTo(this.delegate);