[jboss-cvs] jboss-jms/tests/src/org/jboss/test/messaging/core/distributed/queue ...

[Timothy Fox]

  User: timfox  
  Date: 06/07/17 13:14:51

  Modified:    tests/src/org/jboss/test/messaging/core/distributed/queue 
                        RecoverableDistributedQueueTest.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.13      +5 -3      jboss-jms/tests/src/org/jboss/test/messaging/core/distributed/queue/RecoverableDistributedQueueTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: RecoverableDistributedQueueTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/distributed/queue/RecoverableDistributedQueueTest.java,v
  retrieving revision 1.12
  retrieving revision 1.13
  diff -u -b -r1.12 -r1.13
  --- RecoverableDistributedQueueTest.java	27 Jun 2006 19:44:40 -0000	1.12
  +++ RecoverableDistributedQueueTest.java	17 Jul 2006 17:14:51 -0000	1.13
  @@ -28,11 +28,13 @@
   import org.jboss.messaging.core.plugin.contract.PersistenceManager;
   import org.jboss.test.messaging.core.distributed.queue.base.DistributedQueueTestBase;
   
  +import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
  +
   /**
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  - * @version <tt>$Revision: 1.12 $</tt>
  + * @version <tt>$Revision: 1.13 $</tt>
    *
  - * $Id: RecoverableDistributedQueueTest.java,v 1.12 2006/06/27 19:44:40 timfox Exp $
  + * $Id: RecoverableDistributedQueueTest.java,v 1.13 2006/07/17 17:14:51 timfox Exp $
    */
   public class RecoverableDistributedQueueTest extends DistributedQueueTestBase
   {
  @@ -118,7 +120,7 @@
   
      public void recoverChannel() throws Exception
      {
  -      channel = new Queue(-1, ms, tl, null, true, 0, 0, 0);
  +      channel = new Queue(-1, ms, tl, null, true, 0, 0, 0, new QueuedExecutor());
      }