User: starksm
Date: 02/04/04 19:38:07
Modified: src/main/org/jboss/test/web/servlets Tag: Branch_2_4
EJBServlet.java ENCServlet.java
Log:
Add tests of accessing ejbs through local interfaces from a servlet
Revision Changes Path
No revision
No revision
1.2.2.1 +10 -3 jbosstest/src/main/org/jboss/test/web/servlets/EJBServlet.java
Index: EJBServlet.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/web/servlets/EJBServlet.java,v
retrieving revision 1.2
retrieving revision 1.2.2.1
diff -u -r1.2 -r1.2.2.1
--- EJBServlet.java 7 May 2001 16:59:08 -0000 1.2
+++ EJBServlet.java 5 Apr 2002 03:38:07 -0000 1.2.2.1
@@ -15,12 +15,14 @@
import org.jboss.test.web.interfaces.ReferenceTest;
import org.jboss.test.web.interfaces.StatelessSession;
import org.jboss.test.web.interfaces.StatelessSessionHome;
+import org.jboss.test.web.interfaces.StatelessSessionLocal;
+import org.jboss.test.web.interfaces.StatelessSessionLocalHome;
import org.jboss.test.web.util.Util;
/** A servlet that accesses an EJB.
@author [EMAIL PROTECTED]
-@version $Revision: 1.2 $
+@version $Revision: 1.2.2.1 $
*/
public class EJBServlet extends HttpServlet
{
@@ -30,13 +32,18 @@
try
{
InitialContext ctx = new InitialContext();
- StatelessSessionHome home = (StatelessSessionHome)
ctx.lookup("java:comp/env/ejb/OptimizedEJB");
+ Context enc = (Context) ctx.lookup("java:comp/env");
+ StatelessSessionHome home = (StatelessSessionHome)
enc.lookup("ejb/OptimizedEJB");
StatelessSession bean = home.create();
bean.noop(new ReferenceTest(), true);
+
+ StatelessSessionLocalHome localHome = (StatelessSessionLocalHome)
enc.lookup("ejb/local/OptimizedEJB");
+ StatelessSessionLocal localBean = localHome.create();
+ localBean.noop(new ReferenceTest(), true);
}
catch(Exception e)
{
- throw new ServletException("Failed to call OptimizedEJB", e);
+ throw new ServletException("Failed to call OptimizedEJB through remote
and local interfaces", e);
}
response.setContentType("text/html");
PrintWriter out = response.getWriter();
1.2.2.2 +59 -23 jbosstest/src/main/org/jboss/test/web/servlets/ENCServlet.java
Index: ENCServlet.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/web/servlets/ENCServlet.java,v
retrieving revision 1.2.2.1
retrieving revision 1.2.2.2
diff -u -r1.2.2.1 -r1.2.2.2
--- ENCServlet.java 9 Jul 2001 01:06:06 -0000 1.2.2.1
+++ ENCServlet.java 5 Apr 2002 03:38:07 -0000 1.2.2.2
@@ -2,6 +2,8 @@
import java.io.IOException;
import java.io.PrintWriter;
+import javax.jms.QueueConnectionFactory;
+import javax.mail.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
@@ -12,15 +14,20 @@
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;
+import org.jboss.test.web.interfaces.StatelessSessionHome;
+import org.jboss.test.web.interfaces.StatelessSessionLocalHome;
+
import org.jboss.test.web.util.Util;
-/**
+/** Tests of the server ENC naming context
*
- * @author [EMAIL PROTECTED]
- * @version $Revision: 1.2.2.1 $
+ * @author [EMAIL PROTECTED]
+ * @version $Revision: 1.2.2.2 $
*/
public class ENCServlet extends HttpServlet
{
+ org.apache.log4j.Category log =
org.apache.log4j.Category.getInstance(getClass());
+
protected void processRequest(HttpServletRequest request, HttpServletResponse
response)
throws ServletException, IOException
{
@@ -61,8 +68,13 @@
}
catch(NamingException e)
{
- e.printStackTrace();
- throw new ServletException("ENC tests failed", e);
+ log.debug("Lookup failed", e);
+ throw new ServletException("Lookup failed, ENC tests failed", e);
+ }
+ catch(RuntimeException e)
+ {
+ log.debug("Runtime error", e);
+ throw new ServletException("Runtime error, ENC tests failed", e);
}
}
@@ -70,50 +82,74 @@
{
// Basic env values
Integer i = (Integer) myEnv.lookup("Ints/i0");
- System.out.println("Ints/i0 = "+i);
+ log.debug("Ints/i0 = "+i);
i = (Integer) initCtx.lookup("java:comp/env/Ints/i1");
- System.out.println("Ints/i1 = "+i);
+ log.debug("Ints/i1 = "+i);
Float f = (Float) myEnv.lookup("Floats/f0");
- System.out.println("Floats/f0 = "+f);
+ log.debug("Floats/f0 = "+f);
f = (Float) initCtx.lookup("java:comp/env/Floats/f1");
- System.out.println("Floats/f1 = "+f);
+ log.debug("Floats/f1 = "+f);
String s = (String) myEnv.lookup("Strings/s0");
- System.out.println("Strings/s0 = "+s);
+ log.debug("Strings/s0 = "+s);
s = (String) initCtx.lookup("java:comp/env/Strings/s1");
- System.out.println("Strings/s1 = "+s);
+ log.debug("Strings/s1 = "+s);
s = (String) initCtx.lookup("java:comp/env/ejb/catalog/CatalogDAOClass");
- System.out.println("ejb/catalog/CatalogDAOClass = "+s);
+ log.debug("ejb/catalog/CatalogDAOClass = "+s);
}
private void testEjbRefs(Context initCtx, Context myEnv) throws NamingException
{
// EJB References
Object ejb = myEnv.lookup("ejb/bean0");
- System.out.println("ejb/bean0 = "+ejb);
+ if( (ejb instanceof StatelessSessionHome) == false )
+ throw new NamingException("ejb/bean0 is not a StatelessSessionHome");
+ log.debug("ejb/bean0 = "+ejb);
ejb = initCtx.lookup("java:comp/env/ejb/bean1");
- System.out.println("ejb/bean1 = "+ejb);
+ if( (ejb instanceof StatelessSessionHome) == false )
+ throw new NamingException("ejb/bean1 is not a StatelessSessionHome");
+ log.debug("ejb/bean1 = "+ejb);
ejb = initCtx.lookup("java:comp/env/ejb/bean2");
- System.out.println("ejb/bean2 = "+ejb);
+ if( (ejb instanceof StatelessSessionHome) == false )
+ throw new NamingException("ejb/bean2 is not a StatelessSessionHome");
+ log.debug("ejb/bean2 = "+ejb);
ejb = initCtx.lookup("java:comp/env/ejb/UnsecuredEJB");
- System.out.println("ejb/UnsecuredEJB = "+ejb);
+ if( (ejb instanceof StatelessSessionHome) == false )
+ throw new NamingException("ejb/UnsecuredEJB is not a
StatelessSessionHome");
+ log.debug("ejb/UnsecuredEJB = "+ejb);
ejb = initCtx.lookup("java:comp/env/ejb/SecuredEJB");
- System.out.println("ejb/SecuredEJB = "+ejb);
+ if( (ejb instanceof StatelessSessionHome) == false )
+ throw new NamingException("ejb/SecuredEJB is not a
StatelessSessionHome");
+ log.debug("ejb/SecuredEJB = "+ejb);
+
+ // EJB Local References
+ ejb = initCtx.lookup("java:comp/env/ejb/local/bean0");
+ if( (ejb instanceof StatelessSessionLocalHome) == false )
+ throw new NamingException("ejb/local/bean0 is not a
StatelessSessionLocalHome");
+ log.debug("ejb/local/bean0 = "+ejb);
+ ejb = initCtx.lookup("java:comp/env/ejb/local/bean1");
+ if( (ejb instanceof StatelessSessionLocalHome) == false )
+ throw new NamingException("ejb/local/bean1 is not a
StatelessSessionLocalHome");
+ log.debug("ejb/local/bean1 = "+ejb);
+ ejb = initCtx.lookup("java:comp/env/ejb/local/OptimizedEJB");
+ if( (ejb instanceof StatelessSessionLocalHome) == false )
+ throw new NamingException("ejb/local/OptimizedEJB is not a
StatelessSessionLocalHome");
+ log.debug("ejb/local/OptimizedEJB = "+ejb);
}
private void testJdbcDataSource(Context initCtx, Context myEnv) throws
NamingException
{
// JDBC DataSource
DataSource ds = (DataSource) myEnv.lookup("jdbc/DefaultDS");
- System.out.println("jdbc/DefaultDS = "+ds);
+ log.debug("jdbc/DefaultDS = "+ds);
}
private void testMail(Context initCtx, Context myEnv) throws NamingException
{
// JavaMail Session
- Object obj = myEnv.lookup("mail/DefaultMail");
- System.out.println("mail/DefaultMail = "+obj);
+ Session session = (Session) myEnv.lookup("mail/DefaultMail");
+ log.debug("mail/DefaultMail = "+session);
}
private void testJMS(Context initCtx, Context myEnv) throws NamingException
{
- // JavaMail Session
- Object obj = myEnv.lookup("jms/QueFactory");
- System.out.println("jms/QueFactory = "+obj);
+ // JMS Factory
+ QueueConnectionFactory qf = (QueueConnectionFactory)
myEnv.lookup("jms/QueFactory");
+ log.debug("jms/QueFactory = "+qf);
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
