1 package org.codehaus.activemq.ra; 2 3 import junit.framework.TestCase; 4 import EDU.oswego.cs.dl.util.concurrent.SynchronizedBoolean; 5 6 /*** 7 */ 8 public class CircularQueueTest extends TestCase { 9 10 11 12 public void testStoppping() throws Exception { 13 SynchronizedBoolean stopping = new SynchronizedBoolean(false); 14 CircularQueue queue = new CircularQueue(10, stopping); 15 for (int i = 0; i < 10; i++) { 16 queue.returnObject(new Object()); 17 } 18 stopping.set(true); 19 int i=0; 20 21 queue.drain(); 22 } 23 24 }