activemq-commits mailing list archives

Author: dejanb
Date: Mon Nov  8 18:06:28 2010
New Revision: 1032653

URL: http://svn.apache.org/viewvc?rev=1032653&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQ-3021 - additional fix

Removed:
    activemq/trunk/activemq-optional/src/test/java/org/apache/activemq/transport/http/BlockingQueueTransportLeakTest.java
Modified:
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java?rev=1032653&r1=1032652&r2=1032653&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java
(original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java
Mon Nov  8 18:06:28 2010
@@ -24,7 +24,6 @@ import java.util.concurrent.TimeUnit;
 import org.apache.activemq.transport.TransportSupport;
 import org.apache.activemq.util.ServiceStopper;
 
-import java.util.concurrent.CountDownLatch;
 /**
  * A server side HTTP based TransportChannel which processes incoming packets
  * and adds outgoing packets onto a {@link Queue} so that they can be dispatched
@@ -33,7 +32,6 @@ import java.util.concurrent.CountDownLat
  * @version $Revision$
  */
 public class BlockingQueueTransport extends TransportSupport {
-	public static CountDownLatch finalizeLatch;
     public static final long MAX_TIMEOUT = 30000L;
 
     private BlockingQueue<Object> queue;
@@ -42,12 +40,6 @@ public class BlockingQueueTransport exte
         this.queue = channel;
     }
 
-    @Override
-    public void finalize()
-    {
-    	finalizeLatch.countDown();
-    }
-
     public BlockingQueue<Object> getQueue() {
         return queue;
     }