You are viewing a plain text version of this content. The canonical link for it is here.
Posted to cactus-dev@jakarta.apache.org by pt...@apache.org on 2008/05/27 15:35:47 UTC
svn commit: r660510 - in
/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb:
./ redirector/
Author: ptahchiev
Date: Tue May 27 06:35:42 2008
New Revision: 660510
URL: http://svn.apache.org/viewvc?rev=660510&view=rev
Log:
Added some sample files to test the ejbRedirector
Added:
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/SampleMDB.java
- copied, changed from r659179, jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/EmailMDB.java
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java (with props)
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java (with props)
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java (with props)
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java (with props)
Removed:
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/EmailMDB.java
Modified:
jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/TestSampleMDB.java
Copied: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/SampleMDB.java (from r659179, jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/EmailMDB.java)
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/SampleMDB.java?p2=jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/SampleMDB.java&p1=jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/EmailMDB.java&r1=659179&r2=660510&rev=660510&view=diff
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/EmailMDB.java (original)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/SampleMDB.java Tue May 27 06:35:42 2008
@@ -1,56 +1,75 @@
package org.apache.cactus.sample.ejb;
-
-import java.util.*;
-import javax.ejb.*;
-import javax.jms.*;
-
-public class EmailMDB implements MessageDrivenBean, MessageListener
-{
-
- private MessageDrivenContext context;
-
- // --------------------------------------------------------------
- // EJB Methods from MessageDrivenBean interface
- // --------------------------------------------------------------
- public void ejbCreate() {
- System.out.println("EmailMDB: ejbCreate called");
- }
-
- public void ejbRemove() {
- System.out.println("EmailMDB: ejbRemove called");
- }
-
- public void setMessageDrivenContext(MessageDrivenContext context) {
- System.out.println("setMessageDrivenContext called");
- this.context = context;
- }
-
-
- // --------------------------------------------------------------
- // Method from MessageListener interface
- // --------------------------------------------------------------
- /**
- * Take in a MapMessage and use the EmailHelper to send out an email message
- */
- public void onMessage(Message message) {
- System.out.println("EmailMDB: onMessage called");
- MapMessage mapmessage = (MapMessage) message;
- try {
-
- // Go through the map message and create a map for sendmail(Map)
- Enumeration e = mapmessage.getMapNames();
- Hashtable mail = new Hashtable();
-
- while (e.hasMoreElements()) {
- String key = (String) e.nextElement();
- String val = mapmessage.getString(key);
- mail.put(key, val);
- }
-
- System.out.println("Sending email: EmailHelper.sendmail(mail)");
-
- } catch(Exception e) {
- e.printStackTrace();
- }
- }
+import javax.ejb.EJBException;
+import javax.ejb.MessageDrivenBean;
+import javax.ejb.MessageDrivenContext;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+import javax.jms.Queue;
+import javax.jms.QueueConnection;
+import javax.jms.QueueConnectionFactory;
+import javax.jms.QueueSender;
+import javax.jms.QueueSession;
+import javax.jms.TextMessage;
+import javax.naming.InitialContext;
+
+
+public class SampleMDB implements MessageDrivenBean, MessageListener {
+
+ MessageDrivenContext context = null;
+ QueueConnection connection;
+ QueueSession session;
+
+ public SampleMDB() {
+ System.out.println("Constructing MyMDB");
+ }
+
+ public void setMessageDrivenContext(MessageDrivenContext context) {
+ this.context = context;
+ System.out.println("setMessageDrivenContext");
+ }
+
+ public void ejbCreate() throws EJBException {
+ System.out.println("ejbCreate");
+ try {
+ InitialContext initContext = new InitialContext();
+ QueueConnectionFactory qcf = (QueueConnectionFactory)
+ initContext.lookup("java:comp/env/jms/QCF");
+ connection = qcf.createQueueConnection();
+ session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+ connection.start();
+ }
+ catch(Exception e) {
+ throw new EJBException("Failed to initialize MyMDB", e);
+ }
+ }
+
+ public void ejbRemove() {
+ System.out.println("ejbRemove");
+ context = null;
+ try {
+ if( session != null )
+ session.close();
+ if( connection != null )
+ connection.close();
+ }
+ catch(JMSException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void onMessage(Message msg) {
+ System.out.println("onMessage");
+ try {
+ TextMessage message = (TextMessage) msg;
+ Queue queue = (Queue) msg.getJMSReplyTo();
+ QueueSender sender = session.createSender(queue);
+ TextMessage message2 = session.createTextMessage(message.getText());
+ sender.send(message2);
+ sender.close();
+ }
+ catch(Exception e) {
+ e.printStackTrace();
+ }
+ }
}
Modified: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/TestSampleMDB.java
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/TestSampleMDB.java?rev=660510&r1=660509&r2=660510&view=diff
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/TestSampleMDB.java (original)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/TestSampleMDB.java Tue May 27 06:35:42 2008
@@ -33,6 +33,7 @@
import javax.naming.InitialContext;
import javax.naming.NamingException;
+import org.apache.cactus.JmsRequest;
import org.apache.cactus.JmsTestCase;
/**
@@ -43,8 +44,8 @@
public class TestSampleMDB extends JmsTestCase
{
private static String QUEUE_NAME = "CactusQueue";
- private static String PROVIDER_URL = "t3://localhost:7001";
- private static String CONNECTION_FACTORY = "javax.jms.QueueConnectionFactory";
+ private static String PROVIDER_URL = "jnp://localhost:1099";
+ private static String CONNECTION_FACTORY = "org.jnp.interfaces.NamingContextFactory";
private QueueSender sender;
private QueueSession session;
@@ -81,19 +82,16 @@
super(msg);
}
+ public void beginSayHello(JmsRequest jmsRequest)
+ {
+ System.out.println("Client-side message "+message);
+ }
+
public void testSayHello()
{
-
-
- // send the mapmessage to the Queue
- try
- {
- sender.send(message);
- this.message.setStringProperty("aaaa", "bbbb");
- } catch (JMSException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
+ System.out.println("Message:"+message);
+ //sender.send(message);
+ //this.message.setStringProperty("aaaa", "bbbb");
}
/**
@@ -105,10 +103,10 @@
*/
private Context getInitialContext() throws NamingException {
Properties env = new Properties();
- env.put("cactus.jndi.initialContextFactory", "weblogic.jndi.WLInitialContextFactory");
+ env.put("cactus.jndi.initialContextFactory", "org.jnp.interfaces.NamingContextFactory");
env.put("cactus.jndi.providerUrl", PROVIDER_URL);
env.put("cactus.jndi.securityPrincipal", "system");
- env.put("cactus.jndi.securityCredentials", "weblogic");
+ env.put("cactus.jndi.securityCredentials", "jboss");
return new InitialContext(env);
}
Added: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java?rev=660510&view=auto
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java (added)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java Tue May 27 06:35:42 2008
@@ -0,0 +1,57 @@
+package org.apache.cactus.sample.ejb.redirector;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.rmi.PortableRemoteObject;
+import junit.framework.Test;
+import junit.framework.TestSuite;
+import org.apache.cactus.*;
+/**
+ * Prototype of EJBRedirector for Cactus.
+ * @author Siddhartha P. Chandurkar (siddhartha@visioncodified.com)
+ */
+
+public class FirstTest extends EJBTestCase {
+
+ ITestBean test;
+
+ public FirstTest(String name) {
+ super(name);
+ }
+
+ public static Test suite() {
+ return new TestSuite(FirstTest.class);
+ }
+
+ public void setUp() {
+ System.out.println("Set Up for TestBean");
+ try {
+ Context ctx = new InitialContext();
+ TestHome home =
+ (TestHome) PortableRemoteObject.narrow(
+ ctx.lookup("CACTUS/TEST"),
+ TestHome.class);
+ test = home.create();
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void testSum() throws Exception {
+ System.out.println("Test for SUM");
+ assertEquals(3, test.sum(2, 2));
+ }
+ public void testMultiply() throws Exception {
+ System.out.println("Test for Multiply");
+ assertEquals(4, test.multiply(2, 2));
+ }
+ public void tearDown() {
+ System.out.println("Tear Down for TestBean");
+ test = null;
+ }
+ public static void main(String args[]) {
+ junit.textui.TestRunner.run(suite());
+ }
+
+}
Propchange: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/FirstTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java?rev=660510&view=auto
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java (added)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java Tue May 27 06:35:42 2008
@@ -0,0 +1,17 @@
+package org.apache.cactus.sample.ejb.redirector;
+
+import java.rmi.RemoteException;
+import javax.ejb.EJBObject;
+
+/**
+ * Prototype of EJBRedirector for Cactus.
+ * @author Siddhartha P. Chandurkar (siddhartha@visioncodified.com)
+ */
+
+public interface ITestBean extends EJBObject {
+
+ //METHODS
+ int sum(int a, int b) throws RemoteException;
+ int multiply(int a, int b) throws RemoteException;
+
+}
\ No newline at end of file
Propchange: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/ITestBean.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java?rev=660510&view=auto
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java (added)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java Tue May 27 06:35:42 2008
@@ -0,0 +1,65 @@
+package org.apache.cactus.sample.ejb.redirector;
+
+import javax.ejb.CreateException;
+import javax.ejb.SessionBean;
+import javax.ejb.SessionContext;
+
+/**
+ * Prototype of EJBRedirector for Cactus.
+ * @author Siddhartha P. Chandurkar (siddhartha@visioncodified.com)
+ */
+
+public class TestBean implements SessionBean {
+
+ //Attributes
+ private SessionContext context;
+
+ //METHODS
+
+ public int sum(int a, int b) {
+ return a + b;
+ }
+ public int multiply(int a, int b) {
+ return a * b;
+ }
+
+ /**
+ * No argument constructor needed by the Container
+ */
+ public TestBean() {
+
+ }
+ /**
+ * Create method specified in EJB 1.1 section 6.10.3
+ */
+ public void ejbCreate() throws CreateException {
+ }
+
+ /* Methods required by SessionBean Interface. EJB 1.1 section 6.5.1. */
+
+ /**
+ * @see javax.ejb.SessionBean#setContext(javax.ejb.SessionContext)
+ */
+ public void setSessionContext(SessionContext context) {
+ this.context = context;
+ }
+
+ /**
+ * @see javax.ejb.SessionBean#ejbActivate()
+ */
+ public void ejbActivate() {
+ }
+
+ /**
+ * @see javax.ejb.SessionBean#ejbPassivate()
+ */
+ public void ejbPassivate() {
+ }
+
+ /**
+ * @see javax.ejb.SessionBean#ejbRemove()
+ */
+ public void ejbRemove() {
+ }
+
+}
Propchange: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestBean.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java
URL: http://svn.apache.org/viewvc/jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java?rev=660510&view=auto
==============================================================================
--- jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java (added)
+++ jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java Tue May 27 06:35:42 2008
@@ -0,0 +1,15 @@
+package org.apache.cactus.sample.ejb.redirector;
+
+import java.rmi.RemoteException;
+import javax.ejb.CreateException;
+import javax.ejb.EJBHome;
+
+/**
+ * Prototype of EJBRedirector for Cactus.
+ * @author Siddhartha P. Chandurkar (siddhartha@visioncodified.com)
+ */
+
+public interface TestHome extends EJBHome {
+ public ITestBean create() throws RemoteException, CreateException;
+
+}
Propchange: jakarta/cactus/trunk/samples/ejb/src/main/java/org/apache/cactus/sample/ejb/redirector/TestHome.java
------------------------------------------------------------------------------
svn:eol-style = native
---------------------------------------------------------------------
To unsubscribe, e-mail: cactus-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: cactus-dev-help@jakarta.apache.org