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

[Timothy Fox]

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

  Modified:    tests/src/org/jboss/test/messaging  MessagingTestCase.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.17      +4 -4      jboss-jms/tests/src/org/jboss/test/messaging/MessagingTestCase.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MessagingTestCase.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/MessagingTestCase.java,v
  retrieving revision 1.16
  retrieving revision 1.17
  diff -u -b -r1.16 -r1.17
  --- MessagingTestCase.java	29 Mar 2006 18:51:23 -0000	1.16
  +++ MessagingTestCase.java	17 Jul 2006 17:14:50 -0000	1.17
  @@ -39,8 +39,8 @@
    *
    * @author <a href="mailto:adrian at jboss.org">Adrian Brock</a>
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  - * @version <tt>$Revision: 1.16 $</tt>
  - * $Id: MessagingTestCase.java,v 1.16 2006/03/29 18:51:23 timfox Exp $
  + * @version <tt>$Revision: 1.17 $</tt>
  + * $Id: MessagingTestCase.java,v 1.17 2006/07/17 17:14:50 timfox Exp $
    */
   public class MessagingTestCase extends TestCase
   {
  @@ -108,7 +108,7 @@
            log.trace("Draining messages from " + dest);
            while (true)
            {
  -            m = cons.receiveNoWait();
  +            m = cons.receive(500);
               if (m == null) break;
               log.trace("Drained message");
            }         
  @@ -133,7 +133,7 @@
            log.trace("Draining messages from " + topic + ":" + subName);
            while (true)
            {
  -            m = cons.receiveNoWait();
  +            m = cons.receive(500);
               if (m == null) break;
               log.trace("Drained message");
            }