[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
Re: [jetty-users] Embedded jetty-all 8.1.x JNDI + Atomikos + OpenJPA 2.x

Thanks for the tip Jan! That seemed to get me further than I was...

I'm still running into an issue with the Transaction and I believe it's
related to the JNDI lookup. According to
http://wiki.eclipse.org/Jetty/Feature/JNDI#Configuring_XA_Transactions all
that is required is to add a new org.eclipse.jetty.plus.jndi.Transaction
passing in com.atomikos.icatch.jta.J2eeUserTransaction (which I found out is
for an older version of Atomikos; supposed to use
com.atomikos.icatch.jta.UserTransactionImp). It also states that we can then
lookup "java:comp/UserTransaction in your web app", but doesn't say how to
do this if we are just using a handler. Even so, if that is all that is
needed in a webapp, how does Jetty instantiate the
com.atomikos.icatch.jta.UserTransactionManager? I found that I had to add a
static call to com.atomikos.icatch.jta.UserTransactionManager.init() to my
Jetty configuration to get the transaction manager running. I then added a
org.eclipse.jetty.plus.jndi.Resource so it could be looked up by OpenJPA in
the persistence.xml (below). That all seems to work and I can get data back
from queries to the database, but I can't seem to get the
org.eclipse.jetty.plus.jndi.Transaction to be recognized. Is there another
step that I'm missing to get Jetty to expose the Transaction? Maybe a way to
get Jetty to instantiate the transaction manager instead of doing it myself
in the jetty configuration?

META-INF/jetty.xml

<?xml version="1.0"?>
<!DOCTYPE Configure PUBLIC "-//Mort Bay Consulting//DTD Configure//EN"
"http://www.eclipse.org/jetty/configure.dtd";>
<Configure id="Server" class="org.eclipse.jetty.server.Server">
	<New id="txMgr"
class="com.atomikos.icatch.jta.UserTransactionManager">
		<Call name="init" />
	</New>
	<New id="txMgrResource"
class="org.eclipse.jetty.plus.jndi.Resource">
		<Arg></Arg>
		<Arg>java:comp/UserTransactionManager</Arg>
		<Arg>
			<Ref id="txMgr" />
		</Arg>
	</New>
	<New id="tx" class="org.eclipse.jetty.plus.jndi.Transaction">
		<Arg>
			<New
class="com.atomikos.icatch.jta.UserTransactionImp" />
		</Arg>
	</New>
	<New id="atomikosDS" class="org.eclipse.jetty.plus.jndi.Resource">
		<Arg></Arg>
		<Arg>jdbc/myDS</Arg>
		<Arg>
			<New id="atomikosDS"
class="com.atomikos.jdbc.AtomikosDataSourceBean">
				<Set name="minPoolSize">2</Set>
				<Set name="maxPoolSize">50</Set>
				<Set
name="xaDataSourceClassName">org.h2.jdbcx.JdbcDataSource</Set>
				<Set
name="UniqueResourceName">jdbc/myDS</Set>
				<Set name="testQuery">SELECT 1 and SELECT 1
FROM DUAL</Set>
				<Get name="xaProperties">
					<Call name="setProperty">
						<!-- Must be upper case -->
						<Arg>URL</Arg>
	
<Arg>jdbc:h2:~/testDB;AUTO_SERVER=TRUE;FILE_LOCK=SOCKET;TRACE_LEVEL_FILE=0;T
RACE_LEVEL_SYSTEM_OUT=1</Arg>
					</Call>
					<Call name="setProperty">
						<Arg>user</Arg>
						<Arg>sa</Arg>
					</Call>
					<Call name="setProperty">
						<Arg>password</Arg>
						<Arg>sa</Arg>
					</Call>
				</Get>
			</New>
		</Arg>
	</New>
	<Ref id='Server'>
		<Call name="addBean">
			<Arg>
				<New
class="org.eclipse.jetty.jndi.DataSourceCloser">
					<Arg>
						<Ref id="atomikosDS" />
					</Arg>
				</New>
			</Arg>
		</Call>
	</Ref>
</Configure>

META-INF/persistence.xml

<?xml version="1.0"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence";
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
	xsi:schemaLocation="http://java.sun.com/xml/ns/persistence 
        http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd";
	version="2.0">
	<persistence-unit name="test-pu" transaction-type="JTA">
	
<provider>org.apache.openjpa.persistence.PersistenceProviderImpl</provider>
		<jta-data-source>jdbc/myDS</jta-data-source>
		<class>com.example.jpa.Message</class>
		<properties>	
			<property name="openjpa.jdbc.SynchronizeMappings"
value="buildSchema(ForeignKeys=true)"/>
			<property name="openjpa.jdbc.JDBCListeners"
value="org.ugate.service.UGateJdbcListener"/>
<!-- 			<property name="openjpa.DynamicEnhancementAgent"
value="false"/> -->
			<property name="openjpa.ConnectionFactoryProperties"
value="PrettyPrint=true, PrettyPrintLineLength=72" />
			<property name="openjpa.Log"
value="DefaultLevel=WARN, Tool=INFO, SQL=WARN"/>

			<property name="openjpa.ConnectionFactoryMode"
value="managed" />
			<property name="openjpa.TransactionMode"
value="managed" />
			<property name="openjpa.ManagedRuntime"
	
value="jndi(TransactionManagerName=java:comp/UserTransactionManager)" />
		</properties>
	</persistence-unit>
</persistence>

transactions.properties (root of my class path)

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionSe
rviceFactory
com.atomikos.icatch.output_dir=${java.io.tmpdir}/atomikos/logs
com.atomikos.icatch.log_base_dir=${java.io.tmpdir}/atomikos/logs
com.atomikos.icatch.console_log_level=DEBUG

-----Original Message-----
From: jetty-users-bounces@xxxxxxxxxxx
[mailto:jetty-users-bounces@xxxxxxxxxxx] On Behalf Of Jan Bartel
Sent: Saturday, April 28, 2012 7:48 PM
To: JETTY user mailing list
Subject: Re: [jetty-users] Embedded jetty-all 8.1.x JNDI + Atomikos +
OpenJPA 2.x

Will,

java:comp/env is a namespace related to webapps. You don't have a
webapp, just a handler.

Therefore, put your jndi bindings into the  global namespace (rather
than the Server instance's namespace), and then look them up from that
global namespace.
So take out the <Ref id=Server> from the binding of your jndi
resource, then look it up with:


                  ctx = new javax.naming.InitialContext();
                  String configArg = (String) ctx.lookup("jdbc/myDS");

Jan

On 27 April 2012 21:33, Will Hoover <java.whoover@xxxxxxxxx> wrote:
> Hello,
>
>
>
> I am trying to configure Jetty (embedded) to use JTA with Atmikos along
with
> OpenJPA 2.2.0, but I can't seem to get Jetty to recognize my
> org.eclipse.jetty.plus.jndi.Resource
>
>
>
> Java (startup):
>
>                   final Resource serverXml =
> Resource.newSystemResource("META-INF/jetty.xml");
>
>                   final XmlConfiguration configuration = new
> XmlConfiguration(serverXml.getInputStream());
>
>                   server = (Server) configuration.configure();
>
>                   final SelectChannelConnector defaultConnnector = new
> SelectChannelConnector();
>
>                   defaultConnnector.setPort(9080);
>
>                   defaultConnnector.setMaxIdleTime(30000);
>
>                   defaultConnnector.setRequestHeaderSize(8192);
>
>                   server.setConnectors(new Connector[] { defaultConnnector
> });
>
>                   server.setHandler(new DefaultHandler());
>
>                   server.setStopAtShutdown(true);
>
>                   server.start();
>
>                   server.join();
>
>
>
> public class DefaultHandler extends AbstractHandler {
>
>       private static final Logger log =
> LoggerFactory.getLogger(DefaultHandler.class);
>
>
>
>       public void handle(final String target, final Request baseRequest,
> final HttpServletRequest request,
>
>                   final HttpServletResponse response) throws IOException,
> ServletException {
>
>             javax.naming.Context ctx;
>
>             try {
>
>                   ctx = new javax.naming.InitialContext();
>
>                   // Fails here with "javax.naming.NameNotFoundException:
> null"
>
>                   javax.naming.Context envCtx = (javax.naming.Context)
> ctx.lookup("java:comp/env");
>
>                   String configArg = (String) envCtx.lookup("jdbc/myDS");
>
>             } catch (NamingException e) {
>
>                   log.error("No JDBC Resource", e);
>
>             }
>
>             response.setContentType("text/html;charset=utf-8");
>
>             response.setStatus(HttpServletResponse.SC_OK);
>
>             //baseRequest.setHandled(true);
>
>             response.getWriter().println("<h1>Hello World</h1>");
>
>             try {
>
>               // Create a new EntityManagerFactory using the System
> properties.
>
>               // The "hellojpa" name will be used to configure based on
the
>
>               // corresponding name in the META-INF/persistence.xml file
>
>               EntityManagerFactory factory = Persistence.
>
>                   createEntityManagerFactory("test-pu",
> System.getProperties());
>
>
>
>               // Create a new EntityManager from the EntityManagerFactory.
> The
>
>               // EntityManager is the main object in the persistence API,
> and is
>
>               // used to create, delete, and query objects, as well as
> access
>
>               // the current transaction
>
>               EntityManager em = factory.createEntityManager();
>
>
>
>               // Begin a new local transaction so that we can persist a
new
> entity
>
>               em.getTransaction().begin();
>
>
>
>               // Create and persist a new Message entity
>
>               em.persist(new Message("Hello Persistence!"));
>
>
>
>               // Commit the transaction, which will cause the entity to
>
>               // be stored in the database
>
>               em.getTransaction().commit();
>
>
>
>               // It is always good practice to close the EntityManager so
> that
>
>               // resources are conserved.
>
>               em.close();
>
>
>
>               // Create a fresh, new EntityManager
>
>               EntityManager em2 = factory.createEntityManager();
>
>
>
>               // Perform a simple query for all the Message entities
>
>               Query q = em2.createQuery("select m from Message m");
>
>
>
>               // Go through each of the entities and print out each of
their
>
>               // messages, as well as the date on which it was created
>
>               for (Message m : (List<Message>) q.getResultList()) {
>
>                   UGateUtil.PLAIN_LOGGER.info(m.getMessage() + " (created
> on: " + m.getCreated() + ')');
>
>                   response.getWriter().println("<h3>" + m.getMessage() + "
> (created on: " + m.getCreated() + ')' + "</h3>");
>
>               }
>
>
>
>               // Again, it is always good to clean up after ourselves
>
>               em2.close();
>
>               factory.close();
>
>             } catch (Throwable t) {
>
>                   log.error("JPA error: ", t);
>
>             }
>
>       }
>
> }
>
>
>
> META-INF/jetty.xml
>
> <?xml version="1.0"?>
>
> <!DOCTYPE Configure PUBLIC "-//Mort Bay Consulting//DTD Configure//EN"
> "http://www.eclipse.org/jetty/configure.dtd";>
>
> <Configure id="Server" class="org.eclipse.jetty.server.Server">
>
>       <!-- Add a mapping from name in web.xml to the environment -->
>
> <!-- <New id="map1" class="org.eclipse.jetty.plus.jndi.Link"> -->
>
> <!--        <Arg> -->
>
> <!--              <Ref id='Server' /> -->
>
> <!--        </Arg> -->
>
> <!--        <Arg>jdbc/myDS</Arg> -->
>
> <!--        <Arg>jdbc/myDS</Arg> -->
>
> <!-- </New> -->
>
>       <!-- JTA XADataSource -->
>
>       <New id="myDS" class="org.eclipse.jetty.plus.jndi.Resource">
>
>             <Arg>
>
>                   <Ref id="Server" />
>
>             </Arg>
>
>             <Arg>jdbc/myDS</Arg>
>
>             <Arg>
>
>                   <New class="com.atomikos.jdbc.AtomikosDataSourceBean">
>
>                         <Set name="minPoolSize">2</Set>
>
>                         <Set name="maxPoolSize">20</Set>
>
>                         <Set
> name="xaDataSourceClassName">org.h2.jdbcx.JdbcDataSource</Set>
>
>                         <Set name="xaProperties">
>
>                               <New class="java.util.Properties">
>
>                                     <Call name="setProperty">
>
>                                           <Arg>databaseName</Arg>
>
>                                           <Arg>testDB</Arg>
>
>                                     </Call>
>
>                                     <Call name="setProperty">
>
>                                           <Arg>serverName</Arg>
>
>                                           <Arg>localhost</Arg>
>
>                                     </Call>
>
>                                     <Call name="setProperty">
>
>                                           <Arg>portNumber</Arg>
>
>                                           <Arg>5435</Arg>
>
>                                     </Call>
>
>                                     <Call name="setProperty">
>
>                                           <Arg>user</Arg>
>
>                                           <Arg>sa</Arg>
>
>                                     </Call>
>
>                                     <Call name="setProperty">
>
>                                           <Arg>password</Arg>
>
>                                           <Arg>sa</Arg>
>
>                                     </Call>
>
>                               </New>
>
>                         </Set>
>
>                         <Set name="UniqueResourceName">jdbc/myDS</Set>
>
>                   </New>
>
>             </Arg>
>
>       </New>
>
> </Configure>
>
>
>
> META-INF/persistence.xml
>
> <?xml version="1.0"?>
>
> <persistence xmlns="http://java.sun.com/xml/ns/persistence";
>
>       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
>
>       xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
>
>         http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd";
>
>       version="2.0">
>
>       <persistence-unit name="test-pu" transaction-type="JTA">
>
>
>
<provider>org.apache.openjpa.persistence.PersistenceProviderImpl</provider>
>
>             <!-- managed DataSource -->
>
>             <jta-data-source>jdbc/myDS</jta-data-source>
>
>             <class>com.example.jpa.Message</class>
>
>       </persistence-unit>
>
> </persistence>
>
>
>
> Exception when looking up "java:comp/env":
>
> 15:08:45.036 ERROR [qtp144024-32] [o.u.s.w.DefaultServlet:37] No JDBC
> Resource
>
> javax.naming.NameNotFoundException: null
>
>       at
org.eclipse.jetty.jndi.NamingContext.lookup(NamingContext.java:444)
> ~[jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
org.eclipse.jetty.jndi.NamingContext.lookup(NamingContext.java:531)
> ~[jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
org.eclipse.jetty.jndi.NamingContext.lookup(NamingContext.java:546)
> ~[jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.jndi.java.javaRootURLContext.lookup(javaRootURLContext.jav
a:112)
> ~[jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at javax.naming.InitialContext.lookup(InitialContext.java:411)
> ~[na:1.7.0_02]
>
>       at
org.ugate.service.web.DefaultServlet.handle(DefaultServlet.java:34)
> ~[bin/:na]
>
>       at
>
org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:1
11)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at org.eclipse.jetty.server.Server.handle(Server.java:351)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpCo
nnection.java:454)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpC
onnection.java:890)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplet
e(AbstractHttpConnection.java:944)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:634)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
> org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:230)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java
:77)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.
java:609)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.j
ava:45)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:
599)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at
>
org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:5
34)
> [jetty-all-8.1.2.v20120308.jar:8.1.2.v20120308]
>
>       at java.lang.Thread.run(Thread.java:722) [na:1.7.0_02]
>
>
> _______________________________________________
> jetty-users mailing list
> jetty-users@xxxxxxxxxxx
> https://dev.eclipse.org/mailman/listinfo/jetty-users
>
_______________________________________________
jetty-users mailing list
jetty-users@xxxxxxxxxxx
https://dev.eclipse.org/mailman/listinfo/jetty-users