[jboss-cvs] JBoss Messaging SVN: r2603 - in projects/jms-integration/src/main/org/jboss/test/jms/integration: support/ejb20 and 1 other directory.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Wed Apr 25 00:01:22 EDT 2007


Author: clebert.suconic at jboss.com
Date: 2007-04-25 00:01:22 -0400 (Wed, 25 Apr 2007)
New Revision: 2603

Added:
   projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulBean.java
   projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulHome.java
   projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulRemote.java
Modified:
   projects/jms-integration/src/main/org/jboss/test/jms/integration/mdb/TransactionedMDBTest.java
   projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java
Log:
Adding integration tests for transaction stuff

Modified: projects/jms-integration/src/main/org/jboss/test/jms/integration/mdb/TransactionedMDBTest.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/mdb/TransactionedMDBTest.java	2007-04-25 03:53:59 UTC (rev 2602)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/mdb/TransactionedMDBTest.java	2007-04-25 04:01:22 UTC (rev 2603)
@@ -23,6 +23,8 @@
 package org.jboss.test.jms.integration.mdb;
 
 
+import java.util.Random;
+
 import javax.jms.Connection;
 import javax.jms.Session;
 import javax.jms.MessageProducer;
@@ -32,6 +34,8 @@
 import junit.framework.*;
 import org.jboss.test.JBossTestSetup;
 import org.jboss.test.jms.integration.MessagingIntegrationTestBase;
+import org.jboss.test.jms.integration.support.ejb20.StatefulHome;
+import org.jboss.test.jms.integration.support.ejb20.StatefulRemote;
 import org.jboss.test.jms.integration.util.JMSAdmin;
 
 /**
@@ -76,10 +80,6 @@
          TextMessage messageResponse = (TextMessage)consumer.receive(10000);
          assertNotNull(messageResponse);
          System.out.println("Received message " + messageResponse.getText());
-
-         messageResponse = (TextMessage)consumer.receive(1000);
-         assertNotNull(messageResponse);
-         assertEquals("NonTransactioned message", messageResponse.getText());
       }
       finally
       {
@@ -88,11 +88,55 @@
             conn.close();
          }
       }
-
    }
+   
+   public void testSendFromEJB() throws Exception
+   {
+      Connection conn = cf.createConnection();
+      conn.start();
+      
+      try
+      {
+    	  
+    	  Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+    	  
+    	  MessageConsumer consumer = sess.createConsumer(responseDestination);
+	
+		   InitialContext ctx = new InitialContext();
+		   StatefulHome home = (StatefulHome)ctx.lookup("ejb/StatefulTest");
+		   StatefulRemote remote = home.create();
+		   Random random = new Random();
+		   String msg = "Msgreturn " + random.nextLong();
+		  
+		   remote.sendTestMessage(msg);
+		   
+		   TextMessage receivedMessage = (TextMessage) consumer.receive(10000);
+		   assertNotNull(receivedMessage);
+		   assertEquals(msg, receivedMessage.getText());
+      }
+      finally
+      {
+    	  if (conn!=null)
+    	  {
+    		  conn.close();
+    	  }
+      }
+	   
+	   
+   }
 
    public static Test suite() throws Exception
    {
+
+	   try
+	   {
+		 System.out.println("Test... Suite");
+	     Class.forName("org.jboss.invocation.InvokerInterceptor").newInstance();
+	   }
+	   catch (Throwable e)
+	   {
+		   e.printStackTrace();
+	   }
       TestSuite suite = new TestSuite();
 
       suite.addTest(new JBossTestSetup(new TestSuite(TransactionedMDBTest.class))
@@ -100,6 +144,7 @@
          protected void setUp() throws Exception
          {
             super.setUp();
+            System.out.println("Hello");
             JMSAdmin admin = MessagingIntegrationTestBase.getDestManager();
             try
             {
@@ -107,10 +152,12 @@
                admin.deployQueue("testQueue_Integration", "queue/testQueue_Integration");
                admin.deployQueue("A_Integration", "queue/A_Integration");
             }
-            catch (Exception e)
+            catch (Throwable e)
             {
                e.printStackTrace();
             }
+            
+            
             deploy ("integration-mdb20-userTransaction.jar");
          }
          protected void tearDown() throws Exception

Added: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulBean.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulBean.java	                        (rev 0)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulBean.java	2007-04-25 04:01:22 UTC (rev 2603)
@@ -0,0 +1,59 @@
+package org.jboss.test.jms.integration.support.ejb20;
+
+import java.rmi.RemoteException;
+
+import javax.jms.*;
+import javax.ejb.CreateException;
+import javax.ejb.EJBException;
+import javax.ejb.SessionBean;
+import javax.ejb.SessionContext;
+import javax.naming.InitialContext;
+
+public class StatefulBean implements SessionBean 
+{
+
+	private static final long serialVersionUID = 7089862891437892169L;
+
+	public void ejbActivate() throws EJBException, RemoteException {
+	}
+
+	public void ejbPassivate() throws EJBException, RemoteException {
+	}
+
+	public void ejbRemove() throws EJBException, RemoteException {
+	}
+
+	public void setSessionContext(SessionContext arg0) throws EJBException, RemoteException 
+	{
+	}
+	
+	public void ejbCreate() throws CreateException
+	{		
+	}
+	
+	public void sendTestMessage(String message) throws JMSException
+	{
+		try
+		{
+		 InitialContext ctx = new InitialContext();
+		 QueueConnectionFactory cf = (QueueConnectionFactory)ctx.lookup("java:comp/env/jms/MyQueueConnectionFactory");
+		 //QueueConnectionFactory cf = (QueueConnectionFactory)ctx.lookup("ConnectionFactory");
+		 System.out.println("cf=" + cf);
+		 System.out.println("cf(2)=" + cf.getClass().getName());
+		 Destination queue = (Destination) ctx.lookup("queue/A_Integration");
+		 Connection conn = cf.createConnection();
+		 Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+		 MessageProducer producer = session.createProducer(queue);
+		 TextMessage msg = session.createTextMessage(message);
+		 producer.send(msg);
+		 conn.close();		 
+		}
+		catch (Exception e)
+		{
+			JMSException jmsE = new JMSException (e.getMessage());
+			jmsE.initCause(e);
+			throw jmsE;
+		}
+	}
+
+}


Property changes on: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulBean.java
___________________________________________________________________
Name: svn:keywords
   + Id LastChangedDate Author Revision

Added: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulHome.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulHome.java	                        (rev 0)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulHome.java	2007-04-25 04:01:22 UTC (rev 2603)
@@ -0,0 +1,8 @@
+package org.jboss.test.jms.integration.support.ejb20;
+
+import javax.ejb.*;
+import java.rmi.RemoteException;
+
+public interface StatefulHome extends EJBHome {
+   public StatefulRemote create() throws RemoteException, CreateException;
+}


Property changes on: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulHome.java
___________________________________________________________________
Name: svn:keywords
   + Id LastChangedDate Author Revision

Added: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulRemote.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulRemote.java	                        (rev 0)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulRemote.java	2007-04-25 04:01:22 UTC (rev 2603)
@@ -0,0 +1,13 @@
+package org.jboss.test.jms.integration.support.ejb20;
+
+import java.rmi.RemoteException;
+
+import javax.ejb.*;
+import javax.jms.JMSException;
+import javax.jms.Destination;
+
+
+public interface StatefulRemote extends EJBObject 
+{
+    public void sendTestMessage(String message) throws JMSException, RemoteException;
+}


Property changes on: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/StatefulRemote.java
___________________________________________________________________
Name: svn:keywords
   + Id LastChangedDate Author Revision

Modified: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java	2007-04-25 03:53:59 UTC (rev 2602)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java	2007-04-25 04:01:22 UTC (rev 2603)
@@ -153,21 +153,7 @@
               conn.close();
            }
          }
-         
-         //userTransaction.begin();
 
-         conn = cf.createConnection();
-         log.info("Creating non transactioned session");
-         session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-         MessageProducer producer = session.createProducer(replyTo);
-         log.info("Sending non Transactional message", new Exception());
-         producer.send(session.createTextMessage("NonTransactioned message"));
-         conn.close();
-
-         //userTransaction.commit();
-         //conn.close();
-
-
       } catch (Exception e)
       {
          log.error(e, e);




More information about the jboss-cvs-commits mailing list