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

[Timothy Fox]

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

  Modified:    tests/src/org/jboss/test/messaging/core/distributed/replicator/base 
                        MultipleReceiversDeliveryTestBase.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.11      +2 -6      jboss-jms/tests/src/org/jboss/test/messaging/core/distributed/replicator/base/MultipleReceiversDeliveryTestBase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MultipleReceiversDeliveryTestBase.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/core/distributed/replicator/base/MultipleReceiversDeliveryTestBase.java,v
  retrieving revision 1.10
  retrieving revision 1.11
  diff -u -b -r1.10 -r1.11
  --- MultipleReceiversDeliveryTestBase.java	13 Mar 2006 05:26:39 -0000	1.10
  +++ MultipleReceiversDeliveryTestBase.java	17 Jul 2006 17:14:51 -0000	1.11
  @@ -22,9 +22,9 @@
   
   /**
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  - * @version <tt>$Revision: 1.10 $</tt>
  + * @version <tt>$Revision: 1.11 $</tt>
    *
  - * $Id: MultipleReceiversDeliveryTestBase.java,v 1.10 2006/03/13 05:26:39 ovidiu Exp $
  + * $Id: MultipleReceiversDeliveryTestBase.java,v 1.11 2006/07/17 17:14:51 timfox Exp $
    */
   public abstract class MultipleReceiversDeliveryTestBase extends DeliveryTestBase
   {
  @@ -103,8 +103,6 @@
         Acknowledgment ack = new Acknowledgment("peer0", new Long(ref.getMessageID()), Acknowledgment.REJECTED);
         ((MultipleReceiversDelivery)delivery).handle(ack);
   
  -      log.info("acknowledgment handled");
  -
         observer.waitForCancellation(delivery);
         assertTrue(delivery.isCancelled());
         assertFalse(delivery.isDone());
  @@ -158,8 +156,6 @@
         Acknowledgment ack = new Acknowledgment("peer0", new Long(ref.getMessageID()), Acknowledgment.ACCEPTED);
         ((MultipleReceiversDelivery)delivery).handle(ack);
   
  -      log.info("acknowledgment handled");
  -
         observer.waitForAcknowledgment(delivery);
         assertTrue(delivery.isDone());
         assertFalse(delivery.isCancelled());