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

[jBoss CVS Development]

  User: pra     
  Date: 01/02/28 01:41:06

  Modified:    src/main/org/jboss/test/mdb/test Main.java
  Log:
  Up to date to new MDB deployment descriptor; new test added for transaction 
handling; error in build.sh corrected
  
  Revision  Changes    Path
  1.3       +8 -8      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.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- Main.java 2001/02/21 05:07:47     1.2
  +++ Main.java 2001/02/28 09:41:06     1.3
  @@ -70,17 +70,16 @@
       /**
        * Test sending messages to Topic testTopic
        */
  -    public void testQueue()
  +    public void testQueue(String name)
        throws Exception {
        QueueSession session = getQueueSession();
  -     // Non portable!!
  -     Queue queue = (Queue)context.lookup("queue/testQueue");
  +     Queue queue = (Queue)context.lookup(name);
        QueueSender sender = session.createSender(queue);
   
  -     System.out.println("TestQueue: Sending 10 messages 1-10");
  +     System.out.println("TestQueue: " + name + " Sending 10 messages 1-10");
        for (int i = 1; i < 11; i++) {
            TextMessage message = session.createTextMessage();
  -         message.setText("Queue Message nr " + i);
  +         message.setText("Queue Message " + name + " nr " + i);
            sender.send(queue, message);
        }
       }
  @@ -90,7 +89,6 @@
        */
       public void testTopic(String name) throws Exception {
        TopicSession session = getTopicSession();
  -     // Non portable!!
        Topic topic = (Topic)context.lookup(name);
        TopicPublisher pub = session.createPublisher(topic);
   
  @@ -160,11 +158,13 @@
            main.setUp();
   
            main.testObjectMessage();
  -         main.testQueue();
  +         main.testQueue("queue/testQueue");
  +
            main.testTopic("topic/testTopic");
            main.testTopic("topic/testDurableTopic");
  -         
            
  +         System.out.println("Testing exception, every other message should be 
rolled back, excpect a lot of stacktraces");
  +         main.testQueue("queue/ex");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println();