[prev in list] [next in list] [prev in thread] [next in thread] 

List:       jboss-cvs-commits
Subject:    [jboss-cvs] jboss-jms/tests/src/org/jboss/test/messaging/jms  ...
From:       Ovidiu Feodorov <ovidiu.feodorov () jboss ! com>
Date:       2005-10-31 19:26:42
Message-ID: E1EWfIo-00005R-NG () committer01 ! frg ! pub ! inap ! atl ! jboss ! com
[Download RAW message or body]

  User: ovidiu  
  Date: 05/10/31 14:26:42

  Modified:    tests/src/org/jboss/test/messaging/jms 
                        MessageConsumerTest.java
  Log:
  more tests
  
  Revision  Changes    Path
  1.51      +81 -15    jboss-jms/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MessageConsumerTest.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java,v
  retrieving revision 1.50
  retrieving revision 1.51
  diff -u -b -r1.50 -r1.51
  --- MessageConsumerTest.java	31 Oct 2005 14:10:51 -0000	1.50
  +++ MessageConsumerTest.java	31 Oct 2005 19:26:42 -0000	1.51
  @@ -62,9 +62,9 @@
   /**
    * @author <a href="mailto:ovidiu@jboss.org">Ovidiu Feodorov</a>
    * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a>
  - * @version <tt>$Revision: 1.50 $</tt>
  + * @version <tt>$Revision: 1.51 $</tt>
    *
  - * $Id: MessageConsumerTest.java,v 1.50 2005/10/31 14:10:51 timfox Exp $
  + * $Id: MessageConsumerTest.java,v 1.51 2005/10/31 19:26:42 ovidiu Exp $
    */
   public class MessageConsumerTest extends MessagingTestCase
   {
  @@ -198,18 +198,15 @@
         Message m = producerSession.createMessage();
         queueProducer.send(m);
   
  -      // the message is in the channel
  +      // the message is in the channel, however the queue maintains it as "not delivered"
   
         QueueBrowser browser = producerSession.createBrowser(queue);
         Enumeration e = browser.getEnumeration();
  -
  -      // however the queue maintains it as "not delivered"
         Message bm = (Message)e.nextElement();
         assertEquals(m.getJMSMessageID(), bm.getJMSMessageID());
         assertFalse(e.hasMoreElements());
   
  -
  -      // create a second consumer and try to receive from queue, it should return null
  +      // create a second consumer and try to receive from queue, it should return the message 
         MessageConsumer queueConsumer2 = consumerSession.createConsumer(queue);
   
         Message rm = queueConsumer2.receive(3000);
  @@ -1519,6 +1516,7 @@
      public void testMessageListenerOnTopic() throws Exception
      {
         if (log.isTraceEnabled()) log.trace("testMessageListenerOnTopic");
  +
         MessageListenerImpl l = new MessageListenerImpl();
         topicConsumer.setMessageListener(l);
   
  @@ -1534,6 +1532,76 @@
         assertEquals(m1.getJMSMessageID(), l.getNextMessage().getJMSMessageID());
      }
   
  +
  +//   TODO: enable this
  +//   public void testMessageListenerOnTopicMultipleMessages() throws Exception
  +//   {
  +//      log.debug("testMessageListenerOnTopicMultipleMessages");
  +//
  +//      MessageListenerImpl l = new MessageListenerImpl();
  +//      topicConsumer.setMessageListener(l);
  +//
  +//      consumerConnection.start();
  +//
  +//      int NUM_MESSAGES = 10;
  +//      for(int i = 0; i < NUM_MESSAGES; i++)
  +//      {
  +//         TextMessage m = producerSession.createTextMessage("body" + i);
  +//         topicProducer.send(m);
  +//      }
  +//
  +//      for(int i = 0; i < NUM_MESSAGES; i++)
  +//      {
  +//         l.waitForMessages();
  +//         log.info("got message " + i);
  +//      }
  +//
  +//
  +//      int counter = 0;
  +//      for(Iterator i = l.getMessages().iterator(); i.hasNext(); counter++)
  +//      {
  +//         TextMessage m = (TextMessage)i.next();
  +//         assertEquals("body" + counter, m.getText());
  +//      }
  +//
  +//      log.debug("testMessageListenerOnTopicMultipleMessages done");
  +//   }
  +
  +//   TODO: enable this
  +//   public void testMessageListenerOnQueueMultipleMessages() throws Exception
  +//   {
  +//      log.debug("testMessageListenerOnQueueMultipleMessages");
  +//
  +//      MessageListenerImpl l = new MessageListenerImpl();
  +//      QueueConsumer.setMessageListener(l);
  +//
  +//      consumerConnection.start();
  +//
  +//      int NUM_MESSAGES = 10;
  +//      for(int i = 0; i < NUM_MESSAGES; i++)
  +//      {
  +//         TextMessage m = producerSession.createTextMessage("body" + i);
  +//         queueProducer.send(m);
  +//      }
  +//
  +//      for(int i = 0; i < NUM_MESSAGES; i++)
  +//      {
  +//         l.waitForMessages();
  +//         log.info("got message " + i);
  +//      }
  +//
  +//
  +//      int counter = 0;
  +//      for(Iterator i = l.getMessages().iterator(); i.hasNext(); counter++)
  +//      {
  +//         TextMessage m = (TextMessage)i.next();
  +//         assertEquals("body" + counter, m.getText());
  +//      }
  +//
  +//      log.debug("testMessageListenerOnTopicMultipleMessages done");
  +//   }
  +
  +
      public void testSetMessageListenerTwice() throws Exception
      {
         if (log.isTraceEnabled()) log.trace("testSetMessageListenerTwice");
  @@ -2617,11 +2685,6 @@
         
      }
      
  -   
  -   
  -   
  -   
  -
      // Package protected ---------------------------------------------
   
      // Protected -----------------------------------------------------
  @@ -2632,8 +2695,6 @@
   
      private class RedelMessageListenerImpl implements MessageListener
      {
  -      private Message m;
  -      
         private Session sess;
         
         private int count;
  @@ -2731,7 +2792,7 @@
            log.info("Added message " + m + " to my list");
   
            latch.release();
  -
  +         //latch = new Latch();
         };
   
         public Message getNextMessage()
  @@ -2746,6 +2807,11 @@
            return m;
         }
   
  +      public List getMessages()
  +      {
  +         return messages;
  +      }
  +
         public int size()
         {
            return messages.size();
  
  
  


-------------------------------------------------------
This SF.Net email is sponsored by the JBoss Inc.
Get Certified Today * Register for a JBoss Training Course
Free Certification Exam for All Training Attendees Through End of 2005
Visit http://www.jboss.com/services/certification for more information
_______________________________________________
jboss-cvs-commits mailing list
jboss-cvs-commits@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/jboss-cvs-commits
[prev in list] [next in list] [prev in thread] [next in thread]