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  }