[jBoss-Dev] CVS update:jbosstest/src/main/org/jboss/test/mdb/test Main.java

[jBoss CVS Development]

  User: hiram   
  Date: 01/02/20 21:07:47

  Modified:    src/main/org/jboss/test/mdb/test Main.java
  Log:
  Added a test to the MDB suite: Check to see if ObjectMessages are received correctly
  (and the results were that they were not)
  
  Revision  Changes    Path
  1.2       +19 -3     jbosstest/src/main/org/jboss/test/mdb/test/Main.java
  
  Index: Main.java
  ===================================================================
  RCS file: /products/cvs/ejboss/jbosstest/src/main/org/jboss/test/mdb/test/Main.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- Main.java 2000/12/29 20:57:36     1.1
  +++ Main.java 2001/02/21 05:07:47     1.2
  @@ -20,6 +20,7 @@
   import javax.naming.*;
   
   import javax.jms.*;
  +import org.jboss.test.mdb.bean.CustomMessage;
   
   //import org.jboss.jms.jndi.*;
   
  @@ -101,10 +102,25 @@
        }
       }
   
  +    /**
  +     * Test sending messages to queue testObjectMessage
  +     */
  +    public void testObjectMessage() throws Exception {
   
  -    
  -    
  +     QueueSession session = getQueueSession();
  +     // Non portable!!
  +     Queue queue = (Queue)context.lookup("queue/testObjectMessage");
  +     QueueSender sender = session.createSender(queue);
   
  +     System.out.println("TestQueue: Sending 10 messages 1-10");
  +     for (int i = 1; i < 11; i++) {
  +         ObjectMessage message = session.createObjectMessage();
  +         message.setObject(new CustomMessage(i));
  +         sender.send(queue, message);
  +     }
  +     session.close();
  +    } 
  +
       private QueueSession getQueueSession() throws Exception {
        QueueConnectionFactory queueFactory = 
            (QueueConnectionFactory)context.lookup(QUEUE_FACTORY);
  @@ -143,9 +159,9 @@
            
            main.setUp();
   
  +         main.testObjectMessage();
            main.testQueue();
            main.testTopic("topic/testTopic");
  -         
            main.testTopic("topic/testDurableTopic");