[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