[JBoss-dev] CVS update: jbosstest/src/main/org/jboss/test/jmsra/test RaSyncRecUnitTestCase.java

[Peter Antman]

  User: pra     
  Date: 01/09/22 07:05:22

  Added:       src/main/org/jboss/test/jmsra/test
                        RaSyncRecUnitTestCase.java
  Log:
  Adding test for sync receive
  
  Revision  Changes    Path
  1.1                  
jbosstest/src/main/org/jboss/test/jmsra/test/RaSyncRecUnitTestCase.java
  
  Index: RaSyncRecUnitTestCase.java
  ===================================================================
  /*
  * JBoss, the OpenSource EJB server
  *
  * Distributable under LGPL license.
  * See terms of license at gnu.org.
  */
  package org.jboss.test.jmsra.test;
  import javax.jms.Connection;
  import javax.jms.Message;
  
  import javax.jms.QueueConnection;
  import javax.jms.QueueConnectionFactory;
  import javax.jms.QueueSender;
  import javax.jms.QueueSession;
  import javax.jms.Session;
  import javax.jms.TextMessage;
  import javax.jms.Queue;
  import javax.naming.Context;
  
  import javax.naming.InitialContext;
  import junit.framework.Assert;
  
  import junit.framework.Test;
  
  import org.jboss.test.JBossTestCase;
  
  import org.jboss.test.jmsra.bean.*;
  
  /**
   * 
   * <p>Test sync receive.
   *
   * <p>Created: Sat Sep 22 13:31:54 2001.
   *
   * @author <a href="mailto:[EMAIL PROTECTED]";>Peter Antman</a>
   * @version $Revision: 1.1 $
   */
  
  public class RaSyncRecUnitTestCase extends JBossTestCase {
     private final static String BEAN_JNDI = "QueueRec";
     private final static String QUEUE_FACTORY = "ConnectionFactory";
     private final static String QUEUE = "queue/A";
     private final static int MESSAGE_NR = 10;
     
     /**
      * JMS connection
      */
     protected QueueConnection connection;
     /**
      * JMS session
      */
     protected QueueSession session;
     /**
      * JMS sender
      */
     protected QueueSender sender;
  
     /**
      * Receiving bean
      */ 
     protected QueueRec rec;
  
     /**
      *   
      * Constructor for the RaSyncRecUnitTestCase object
      *
      * @param name           Description of Parameter
      * @exception Exception  Description of Exception
      */
     public RaSyncRecUnitTestCase(String name) {
        super(name);
     }
     
     /**
      * The JUnit setup method
      *
      * @exception Exception  Description of Exception
      */
     protected void setUp() throws Exception
     {
        // Create a receiver
        Context context = getInitialContext();
        try
        {
           QueueRecHome home = (QueueRecHome)context.lookup(BEAN_JNDI);
           rec = home.create();
  
           init(context);
        }
        finally
        {
           context.close();
        }
  
        // start up the session
        connection.start();
  
     }
  
     /**
      * #Description of the Method
      *
      * @param context        Description of Parameter
      * @exception Exception  Description of Exception
      */
     protected void init(final Context context) throws Exception
     {
        QueueConnectionFactory factory =
         (QueueConnectionFactory)context.lookup(QUEUE_FACTORY);
        
        connection = factory.createQueueConnection();
        
        session = ((QueueConnection)connection).createQueueSession(false, 
Session.AUTO_ACKNOWLEDGE);
        
        Queue queue = (Queue)context.lookup(QUEUE);
        
        sender = ((QueueSession)session).createSender(queue);
     }
  
     /**
      * The teardown method for JUnit
      *
      * @exception Exception  Description of Exception
      */
     protected void tearDown() throws Exception
     {
        if (sender != null)
        {
           sender.close();
        }
        if (session != null) { 
         session.close();
        }
        if (connection != null)
        {
           connection.close();
        }
     }
  
     /**
      * Test sync receive of message with jms ra.
      */
     public void testSyncRec() throws Exception {
        // Send a message to queue
        TextMessage message = session.createTextMessage();
        message.setText(String.valueOf(MESSAGE_NR));
        message.setIntProperty(Publisher.JMS_MESSAGE_NR, MESSAGE_NR);
        sender.send(message);
        getLog().debug("sent message with nr = " + MESSAGE_NR);
  
        // Let bean fetch it sync
        int res = rec.getMessage();
        Assert.assertEquals(MESSAGE_NR, res);
        getLog().debug("testSyncRec() OK");
     }
  
     public static Test suite() throws Exception
     {
        return getJ2eeSetup(RaSyncRecUnitTestCase.class, "jmsra.jar");
     }
  } // RaSyncRecUnitTestCase
  
  
  
  
  
  
  
  

_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development