| /* |
| * Copyright (c) 2017, 2020 Oracle and/or its affiliates. All rights reserved. |
| * |
| * This program and the accompanying materials are made available under the |
| * terms of the Eclipse Public License v. 2.0, which is available at |
| * http://www.eclipse.org/legal/epl-2.0. |
| * |
| * This Source Code may also be made available under the following Secondary |
| * Licenses when the conditions for such availability set forth in the |
| * Eclipse Public License v. 2.0 are satisfied: GNU General Public License, |
| * version 2 with the GNU Classpath Exception, which is available at |
| * https://www.gnu.org/software/classpath/license.html. |
| * |
| * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0 |
| */ |
| |
| package com.sun.s1asdev.ejb.ejb30.hello.session3; |
| |
| import java.io.IOException; |
| import java.io.PrintWriter; |
| import java.util.ArrayList; |
| import java.util.Collection; |
| |
| import jakarta.annotation.Resource; |
| import jakarta.ejb.EJB; |
| import jakarta.ejb.EJBs; |
| import jakarta.jms.Connection; |
| import jakarta.jms.ConnectionFactory; |
| import jakarta.jms.JMSConnectionFactoryDefinition; |
| import jakarta.jms.JMSConnectionFactoryDefinitions; |
| import javax.naming.InitialContext; |
| import jakarta.servlet.ServletConfig; |
| import jakarta.servlet.ServletException; |
| import jakarta.servlet.annotation.WebServlet; |
| import jakarta.servlet.http.HttpServlet; |
| import jakarta.servlet.http.HttpServletRequest; |
| import jakarta.servlet.http.HttpServletResponse; |
| import jakarta.transaction.UserTransaction; |
| |
| @EJB(name = "helloStateless3", beanInterface = Hello.class) |
| @EJBs({@EJB(name = "helloStateless4", beanName = "HelloEJB", |
| beanInterface = Hello.class), |
| @EJB(name = "helloStateful3", beanInterface = HelloStateful.class)}) |
| |
| @JMSConnectionFactoryDefinitions( |
| value = { |
| |
| @JMSConnectionFactoryDefinition( |
| description = "global-scope resource defined by @JMSConnectionFactoryDefinition", |
| name = "java:global/env/Servlet_ModByDD_JMSConnectionFactory", |
| interfaceName = "jakarta.jms.ConnectionFactory", |
| resourceAdapter = "jmsra", |
| user = "admin", |
| password = "admin", |
| properties = {"org.glassfish.connector-connection-pool.transaction-support=NoTransaction"}, |
| minPoolSize = 0 |
| ), |
| |
| @JMSConnectionFactoryDefinition( |
| description = "global-scope resource defined by @JMSConnectionFactoryDefinition", |
| name = "java:global/env/Servlet_JMSConnectionFactory", |
| interfaceName = "jakarta.jms.ConnectionFactory", |
| resourceAdapter = "jmsra", |
| user = "admin", |
| password = "admin", |
| properties = {"org.glassfish.connector-connection-pool.transaction-support=XATransaction"}, |
| minPoolSize = 0 |
| ), |
| |
| @JMSConnectionFactoryDefinition( |
| description = "application-scope resource defined by @JMSConnectionFactoryDefinition", |
| name = "java:app/env/Servlet_JMSConnectionFactory", |
| interfaceName = "jakarta.jms.ConnectionFactory", |
| // resourceAdapter = "jmsra", |
| user = "admin", |
| password = "admin", |
| properties = {"org.glassfish.connector-connection-pool.transaction-support=XATransaction"}, |
| minPoolSize = 0 |
| ), |
| |
| @JMSConnectionFactoryDefinition( |
| description = "module-scope resource defined by @JMSConnectionFactoryDefinition", |
| name = "java:module/env/Servlet_JMSConnectionFactory", |
| // interfaceName = "jakarta.jms.ConnectionFactory", |
| resourceAdapter = "jmsra", |
| user = "admin", |
| password = "admin", |
| properties = {"org.glassfish.connector-connection-pool.transaction-support=XATransaction"}, |
| minPoolSize = 0 |
| ), |
| |
| @JMSConnectionFactoryDefinition( |
| description = "component-scope resource defined by @JMSConnectionFactoryDefinition", |
| name = "java:comp/env/Servlet_JMSConnectionFactory", |
| // interfaceName = "jakarta.jms.ConnectionFactory", |
| // resourceAdapter = "jmsra", |
| user = "admin", |
| password = "admin", |
| properties = {"org.glassfish.connector-connection-pool.transaction-support=XATransaction"}, |
| minPoolSize = 0 |
| ) |
| |
| } |
| ) |
| |
| @WebServlet(name = "Servlet", urlPatterns = {"/servlet"}) |
| public class Servlet extends HttpServlet { |
| |
| private |
| @EJB |
| Hello helloStateless; |
| private |
| @EJB(beanName = "HelloStatefulEJB") |
| HelloStateful helloStateful; |
| |
| private |
| @Resource |
| UserTransaction ut; |
| |
| private Collection<Connection> connections = new ArrayList<Connection>(); |
| |
| public void init(ServletConfig config) throws ServletException { |
| super.init(config); |
| System.out.println("In JMSConnectionFactory-Definition-Test::servlet... init()"); |
| } |
| |
| public void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { |
| |
| resp.setContentType("text/html"); |
| PrintWriter out = resp.getWriter(); |
| |
| try { |
| // JMSConnectionFactory-Definition through Annotation |
| lookupJMSConnectionFactory("java:global/env/Appclient_ModByDD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:global/env/Appclient_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/Appclient_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/Appclient_Annotation_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/Appclient_Annotation_JMSConnectionFactory", false); |
| |
| lookupJMSConnectionFactory("java:global/env/Servlet_ModByDD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:global/env/Servlet_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/Servlet_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/Servlet_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:comp/env/Servlet_JMSConnectionFactory", true); |
| |
| lookupJMSConnectionFactory("java:global/env/HelloStatefulEJB_ModByDD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:global/env/HelloStatefulEJB_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/HelloStatefulEJB_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/HelloStatefulEJB_Annotation_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/HelloStatefulEJB_Annotation_JMSConnectionFactory", false); |
| |
| lookupJMSConnectionFactory("java:global/env/HelloEJB_ModByDD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:global/env/HelloEJB_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/HelloEJB_Annotation_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/HelloEJB_Annotation_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/HelloEJB_Annotation_JMSConnectionFactory", false); |
| |
| // JMSConnectionFactory-Definition through DD |
| lookupJMSConnectionFactory("java:global/env/Application_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/Application_DD_JMSConnectionFactory", true); |
| |
| lookupJMSConnectionFactory("java:global/env/Appclient_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/Appclient_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/Appclient_DD_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/Appclient_DD_JMSConnectionFactory", false); |
| |
| lookupJMSConnectionFactory("java:global/env/Web_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/Web_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/Web_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:comp/env/Web_DD_JMSConnectionFactory", true); |
| |
| lookupJMSConnectionFactory("java:global/env/HelloStatefulEJB_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/HelloStatefulEJB_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/HelloStatefulEJB_DD_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/HelloStatefulEJB_DD_JMSConnectionFactory", false); |
| |
| lookupJMSConnectionFactory("java:global/env/HelloEJB_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:app/env/HelloEJB_DD_JMSConnectionFactory", true); |
| lookupJMSConnectionFactory("java:module/env/HelloEJB_DD_JMSConnectionFactory", false); |
| lookupJMSConnectionFactory("java:comp/env/HelloEJB_DD_JMSConnectionFactory", false); |
| |
| System.out.println("Servlet lookup jms-connection-factory-definitions successfully!"); |
| |
| System.out.println("beginning tx"); |
| ut.begin(); |
| |
| // invoke method on the EJB |
| System.out.println("invoking stateless ejb"); |
| helloStateless.hello(); |
| |
| System.out.println("committing tx"); |
| ut.commit(); |
| System.out.println("committed tx"); |
| |
| System.out.println("invoking stateless ejb"); |
| helloStateful.hello(); |
| System.out.println("successfully invoked ejbs"); |
| |
| System.out.println("accessing connections"); |
| try { |
| MyThread thread = new MyThread(helloStateful); |
| thread.start(); |
| |
| sleepFor(2); |
| helloStateful.ping(); |
| //throw new EJBException("Did not get ConcurrentAccessException"); |
| } catch (jakarta.ejb.ConcurrentAccessException conEx) { |
| ; //Everything is fine |
| } catch (Throwable th) { |
| throw new Exception("Got some wierd exception: " + th); |
| } |
| |
| System.out.println("Application successfully accessed jms connection factory definitions"); |
| |
| out.println("<HTML> <HEAD> <TITLE> JMS Servlet Output </TITLE> </HEAD> <BODY BGCOLOR=white>"); |
| out.println("<CENTER> <FONT size=+1 COLOR=blue>DatabaseServlet :: All information I can give </FONT> </CENTER> <p> "); |
| out.println("<FONT size=+1 color=red> Context Path : </FONT> " + req.getContextPath() + "<br>"); |
| out.println("<FONT size=+1 color=red> Servlet Path : </FONT> " + req.getServletPath() + "<br>"); |
| out.println("<FONT size=+1 color=red> Path Info : </FONT> " + req.getPathInfo() + "<br>"); |
| out.println("</BODY> </HTML> "); |
| |
| } catch (Exception ex) { |
| ex.printStackTrace(); |
| System.out.println("JMSConnectionFactory-Definition-Test servlet test failed"); |
| throw new ServletException(ex); |
| } finally { |
| closeConnections(); |
| } |
| } |
| |
| public void destroy() { |
| System.out.println("in JMSConnectionFactory-Definition-Test client::servlet destroy"); |
| } |
| |
| class MyThread extends Thread { |
| HelloStateful ref; |
| |
| MyThread(HelloStateful ref) { |
| this.ref = ref; |
| } |
| |
| public void run() { |
| try { |
| ref.sleepFor(2); |
| } catch (Throwable th) { |
| throw new RuntimeException("Could not invoke waitfor() method"); |
| } |
| } |
| } |
| |
| |
| private void sleepFor(int sec) { |
| try { |
| for (int i = 0; i < sec; i++) { |
| Thread.currentThread().sleep(1000); |
| System.out.println("[" + i + "/" + sec + "]: Sleeping...."); |
| } |
| } catch (Exception ex) { |
| } |
| } |
| |
| private void lookupJMSConnectionFactory(String jndiName, boolean expectSuccess) { |
| Connection c = null; |
| try { |
| System.out.println("Servlet lookup jms connection factory: " + jndiName); |
| InitialContext ic = new InitialContext(); |
| ConnectionFactory cf = (ConnectionFactory) ic.lookup(jndiName); |
| c = cf.createConnection(); |
| connections.add(c); |
| System.out.println("Servlet can access jms connection factory: " + jndiName); |
| } catch (Exception e) { |
| if (expectSuccess) { |
| throw new RuntimeException("Servlet failed to access jms connection factory: " + jndiName, e); |
| } |
| System.out.println("Servlet cannot access jms connection factory: " + jndiName); |
| return; |
| |
| } |
| if (!expectSuccess) { |
| throw new RuntimeException("Servlet should not run into here."); |
| } |
| } |
| |
| private void closeConnections() { |
| for (Connection c : connections) { |
| try { |
| c.close(); |
| } catch (Exception e) { |
| } |
| } |
| connections.clear(); |
| } |
| } |