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

[Timothy Fox]

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

  Modified:    tests/src/org/jboss/test/messaging/jms/message 
                        JMSPriorityHeaderTest.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.8       +7 -3      jboss-jms/tests/src/org/jboss/test/messaging/jms/message/JMSPriorityHeaderTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: JMSPriorityHeaderTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/jms/message/JMSPriorityHeaderTest.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -b -r1.7 -r1.8
  --- JMSPriorityHeaderTest.java	28 Mar 2006 14:26:20 -0000	1.7
  +++ JMSPriorityHeaderTest.java	17 Jul 2006 17:14:52 -0000	1.8
  @@ -36,9 +36,9 @@
   
   /**
    * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
  - * @version <tt>$Revision: 1.7 $</tt>
  + * @version <tt>$Revision: 1.8 $</tt>
    *
  - * $Id: JMSPriorityHeaderTest.java,v 1.7 2006/03/28 14:26:20 timfox Exp $
  + * $Id: JMSPriorityHeaderTest.java,v 1.8 2006/07/17 17:14:52 timfox Exp $
    */
   public class JMSPriorityHeaderTest extends MessagingTestCase
   {
  @@ -175,10 +175,12 @@
            assertEquals("a", t.getText());
         }
         {
  -         TextMessage t = (TextMessage)cons.receiveNoWait();
  +         TextMessage t = (TextMessage)cons.receive(500);
            assertNull(t);
         }
         
  +      cons.close();
  +      
         prod.send(m0, DeliveryMode.NON_PERSISTENT, 0, 0);
         prod.send(m1, DeliveryMode.NON_PERSISTENT, 0, 0);
         prod.send(m2, DeliveryMode.NON_PERSISTENT, 0, 0);
  @@ -190,6 +192,8 @@
         prod.send(m8, DeliveryMode.NON_PERSISTENT, 5, 0);
         prod.send(m9, DeliveryMode.NON_PERSISTENT, 6, 0);
         
  +      cons = sessReceive.createConsumer(queue);         
  +      
         {
            TextMessage t = (TextMessage)cons.receive(1000);
            assertNotNull(t);