qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From astitc...@apache.org
Subject svn commit: r1220336 [8/8] - in /qpid/trunk/qpid/java: ./ client/src/main/java/org/apache/qpid/client/ jca/ jca/example/ jca/example/conf/ jca/example/src/ jca/example/src/main/ jca/example/src/main/java/ jca/example/src/main/java/org/ jca/example/src/...
Date Sun, 18 Dec 2011 05:09:10 GMT
Added: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBoss7TransactionManagerLocator.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBoss7TransactionManagerLocator.java?rev=1220336&view=auto
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBoss7TransactionManagerLocator.java
(added)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBoss7TransactionManagerLocator.java
Sun Dec 18 05:09:07 2011
@@ -0,0 +1,33 @@
+package org.apache.qpid.ra.tm;
+
+import javax.naming.InitialContext;
+import javax.transaction.TransactionManager;
+
+public class JBoss7TransactionManagerLocator
+{
+    private static final String TM_JNDI_NAME = "java:jboss/TransactionManager";
+
+    public TransactionManager getTm() throws Exception
+    {
+        InitialContext ctx = null;
+
+        try
+        {
+            ctx = new InitialContext();
+            return (TransactionManager)ctx.lookup(TM_JNDI_NAME);
+        }
+        finally
+        {
+            try
+            {
+                if(ctx != null)
+                {
+                    ctx.close();
+                }
+            }
+            catch(Exception ignore)
+            {
+            }
+        }
+    }
+}

Added: qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBossTransactionManagerLocator.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBossTransactionManagerLocator.java?rev=1220336&view=auto
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBossTransactionManagerLocator.java
(added)
+++ qpid/trunk/qpid/java/jca/src/main/java/org/apache/qpid/ra/tm/JBossTransactionManagerLocator.java
Sun Dec 18 05:09:07 2011
@@ -0,0 +1,70 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.ra.tm;
+
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+
+import javax.transaction.TransactionManager;
+
+/**
+ */
+public class JBossTransactionManagerLocator
+{
+   private final String LOCATOR = "org.jboss.tm.TransactionManagerLocator" ;
+
+   public TransactionManager getTm()
+      throws SecurityException, IllegalArgumentException, IllegalAccessException, InvocationTargetException,
NoSuchMethodException
+   {
+      final ClassLoader classLoader = Thread.currentThread().getContextClassLoader() ;
+      final Class<?> locatorClass ;
+      try
+      {
+         locatorClass = classLoader.loadClass(LOCATOR) ;
+      }
+      catch (final ClassNotFoundException cnfe)
+      {
+         return null ;
+      }
+
+      Method instanceMethod = null ;
+      try
+      {
+         instanceMethod = locatorClass.getMethod("getInstance") ;
+      }
+      catch (final NoSuchMethodException nsme) {} // ignore
+
+      final Object instance ;
+      final String locatorMethodName ;
+      if (instanceMethod != null)
+      {
+         instance = instanceMethod.invoke(null) ;
+         locatorMethodName = "locate" ;
+      }
+      else
+      {
+         instance = null ;
+         locatorMethodName = "locateTransactionManager" ;
+      }
+      final Method locatorMethod = locatorClass.getMethod(locatorMethodName) ;
+      return (TransactionManager) locatorMethod.invoke(instance) ;
+   }
+}

Added: qpid/trunk/qpid/java/jca/src/main/resources/META-INF/jboss-ra.xml
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/resources/META-INF/jboss-ra.xml?rev=1220336&view=auto
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/resources/META-INF/jboss-ra.xml (added)
+++ qpid/trunk/qpid/java/jca/src/main/resources/META-INF/jboss-ra.xml Sun Dec 18 05:09:07
2011
@@ -0,0 +1,33 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements.  See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership.  The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License.  You may obtain a copy of the License at
+ -
+ -   http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied.  See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+ -->
+<jboss-ra>
+  <ra-config-property>
+        <ra-config-property-name>TransactionManagerLocatorClass</ra-config-property-name>
+        <ra-config-property-type>java.lang.String</ra-config-property-type>
+        <ra-config-property-value>org.apache.qpid.ra.tm.JBossTransactionManagerLocator</ra-config-property-value>
+    </ra-config-property>
+    <ra-config-property>
+        <ra-config-property-name>TransactionManagerLocatorMethod</ra-config-property-name>
+        <ra-config-property-type>java.lang.String</ra-config-property-type>
+        <ra-config-property-value>getTm</ra-config-property-value>
+    </ra-config-property>
+</jboss-ra>

Added: qpid/trunk/qpid/java/jca/src/main/resources/META-INF/ra.xml
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/jca/src/main/resources/META-INF/ra.xml?rev=1220336&view=auto
==============================================================================
--- qpid/trunk/qpid/java/jca/src/main/resources/META-INF/ra.xml (added)
+++ qpid/trunk/qpid/java/jca/src/main/resources/META-INF/ra.xml Sun Dec 18 05:09:07 2011
@@ -0,0 +1,220 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements.  See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership.  The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License.  You may obtain a copy of the License at
+ -
+ -   http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied.  See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+ -->
+
+<connector xmlns="http://java.sun.com/xml/ns/j2ee"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+           xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
+           http://java.sun.com/xml/ns/j2ee/connector_1_5.xsd"
+           version="1.5">
+
+  <description>QPID Resource Adapter</description>
+  <display-name>QPID Resource Adapter</display-name>
+
+  <vendor-name>Apache Software Foundation</vendor-name>
+  <eis-type>JMS 1.1 Server</eis-type>
+  <resourceadapter-version>1.0</resourceadapter-version>
+
+  <license>
+    <description>
+      The ASF licenses this file to you under the Apache License,
+      Version 2.0 (the "License"); you may not use this file except
+      in compliance with the License.  You may obtain a copy of the
+      License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+      Unless required by applicable law or agreed to in writing,
+      software distributed under the License is distributed on an
+      "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+      KIND, either express or implied.  See the License for the
+      specific language governing permissions and limitations
+      under the License.
+    </description>
+    <license-required>true</license-required>
+  </license>
+
+  <resourceadapter>
+    <resourceadapter-class>org.apache.qpid.ra.QpidResourceAdapter</resourceadapter-class>
+    <config-property>
+      <description>Client ID for the connection</description>
+      <config-property-name>ClientId</config-property-name>
+      <config-property-type>java.lang.String</config-property-type>
+      <config-property-value>client_id</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Number of setup attempts before failing</description>
+      <config-property-name>SetupAttempts</config-property-name>
+      <config-property-type>java.lang.Integer</config-property-type>
+      <config-property-value>5</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Interval between setup attempts</description>
+      <config-property-name>SetupInterval</config-property-name>
+      <config-property-type>java.lang.Long</config-property-type>
+      <config-property-value>5000</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Use local transactions rather than XA</description>
+      <config-property-name>UseLocalTx</config-property-name>
+      <config-property-type>java.lang.Boolean</config-property-type>
+      <config-property-value>false</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Broker host</description>
+      <config-property-name>Host</config-property-name>
+      <config-property-type>java.lang.String</config-property-type>
+      <config-property-value>localhost</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Broker port</description>
+      <config-property-name>Port</config-property-name>
+      <config-property-type>java.lang.Integer</config-property-type>
+      <config-property-value>5672</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>Virtual Path for Connection Factory</description>
+      <config-property-name>Path</config-property-name>
+      <config-property-type>java.lang.String</config-property-type>
+      <config-property-value>test</config-property-value>
+    </config-property>
+
+    <config-property>
+      <description>connection URL</description>
+      <config-property-name>ConnectionURL</config-property-name>
+      <config-property-type>java.lang.String</config-property-type>
+      <config-property-value>amqp://guest:guest@/test?brokerlist='tcp://localhost:5672'</config-property-value>
+    </config-property>
+
+    <outbound-resourceadapter>
+      <connection-definition>
+        <managedconnectionfactory-class>org.apache.qpid.ra.QpidRAManagedConnectionFactory</managedconnectionfactory-class>
+
+        <config-property>
+          <description>Default session type</description>
+          <config-property-name>sessionDefaultType</config-property-name>
+          <config-property-type>java.lang.String</config-property-type>
+          <config-property-value>javax.jms.Queue</config-property-value>
+        </config-property>
+
+        <config-property>
+          <description>Specify lock timeout in seconds</description>
+          <config-property-name>useTryLock</config-property-name>
+          <config-property-type>java.lang.Integer</config-property-type>
+          <config-property-value>0</config-property-value>
+        </config-property>
+
+        <config-property>
+         <description>Use local transactions rather than XA</description>
+         <config-property-name>UseLocalTx</config-property-name>
+         <config-property-type>java.lang.Boolean</config-property-type>
+         <config-property-value>false</config-property-value>
+       </config-property>
+
+        <config-property>
+          <description>Client ID for the connection</description>
+          <config-property-name>ClientID</config-property-name>
+          <config-property-type>java.lang.String</config-property-type>
+          <config-property-value>client_id</config-property-value>
+        </config-property>
+
+        <config-property>
+          <description>Connection URL</description>
+          <config-property-name>ConnectionURL</config-property-name>
+          <config-property-type>java.lang.String</config-property-type>
+          <config-property-value></config-property-value>
+        </config-property>
+
+        <config-property>
+          <description>Broker host</description>
+          <config-property-name>Host</config-property-name>
+          <config-property-type>java.lang.String</config-property-type>
+          <config-property-value>localhost</config-property-value>
+        </config-property>
+
+        <config-property>
+          <description>Broker port</description>
+          <config-property-name>Port</config-property-name>
+          <config-property-type>java.lang.Integer</config-property-type>
+          <config-property-value>5672</config-property-value>
+        </config-property>
+
+        <config-property>
+          <description>Virtual Path for Connection Factory</description>
+          <config-property-name>Path</config-property-name>
+          <config-property-type>java.lang.String</config-property-type>
+          <config-property-value>test</config-property-value>
+        </config-property>
+
+        <connectionfactory-interface>org.apache.qpid.ra.QpidRAConnectionFactory</connectionfactory-interface>
+        <connectionfactory-impl-class>org.apache.qpid.ra.QpidRAConnectionFactoryImpl</connectionfactory-impl-class>
+        <connection-interface>javax.jms.Session</connection-interface>
+        <connection-impl-class>org.apache.qpid.ra.QpidRASessionImpl</connection-impl-class>
+      </connection-definition>
+      <transaction-support>XATransaction</transaction-support>
+      <authentication-mechanism>
+        <authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
+        <credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
+      </authentication-mechanism>
+      <reauthentication-support>false</reauthentication-support>
+    </outbound-resourceadapter>
+      <inbound-resourceadapter>
+        <messageadapter>
+          <messagelistener>
+            <messagelistener-type>javax.jms.MessageListener</messagelistener-type>
+            <activationspec>
+              <activationspec-class>org.apache.qpid.ra.inflow.QpidActivationSpec</activationspec-class>
+              <required-config-property>
+                <config-property-name>destination</config-property-name>
+              </required-config-property>
+            </activationspec>
+          </messagelistener>
+        </messageadapter>
+      </inbound-resourceadapter>
+
+      <adminobject>
+            <adminobject-interface>javax.jms.Destination</adminobject-interface>
+            <adminobject-class> org.apache.qpid.ra.admin.QpidDestinationProxy</adminobject-class>
+            <config-property>
+                <config-property-name>destinationAddress </config-property-name>
+                <config-property-type>java.lang.String </config-property-type>
+            </config-property>
+            <config-property>
+                <config-property-name>destinationType</config-property-name>
+                <config-property-type>java.lang.String </config-property-type>
+            </config-property>
+        </adminobject>
+      <adminobject>
+            <adminobject-interface>javax.jms.ConnectionFactory</adminobject-interface>
+            <adminobject-class> org.apache.qpid.ra.admin.QpidConnectionFactoryProxy</adminobject-class>
+            <config-property>
+                <config-property-name>connectionURL</config-property-name>
+                <config-property-type>java.lang.String </config-property-type>
+            </config-property>
+        </adminobject>
+   </resourceadapter>
+</connector>

Propchange: qpid/trunk/qpid/java/jca/src/main/resources/META-INF/ra.xml
------------------------------------------------------------------------------
    svn:executable = *

Added: qpid/trunk/qpid/java/lib/geronimo-ejb_3.0_spec-1.0.1.jar
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/lib/geronimo-ejb_3.0_spec-1.0.1.jar?rev=1220336&view=auto
==============================================================================
Files qpid/trunk/qpid/java/lib/geronimo-ejb_3.0_spec-1.0.1.jar (added) and qpid/trunk/qpid/java/lib/geronimo-ejb_3.0_spec-1.0.1.jar
Sun Dec 18 05:09:07 2011 differ

Added: qpid/trunk/qpid/java/lib/geronimo-j2ee-connector_1.5_spec-2.0.0.jar
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/lib/geronimo-j2ee-connector_1.5_spec-2.0.0.jar?rev=1220336&view=auto
==============================================================================
Files qpid/trunk/qpid/java/lib/geronimo-j2ee-connector_1.5_spec-2.0.0.jar (added) and qpid/trunk/qpid/java/lib/geronimo-j2ee-connector_1.5_spec-2.0.0.jar
Sun Dec 18 05:09:07 2011 differ

Added: qpid/trunk/qpid/java/lib/geronimo-jta_1.1_spec-1.1.1.jar
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/lib/geronimo-jta_1.1_spec-1.1.1.jar?rev=1220336&view=auto
==============================================================================
Files qpid/trunk/qpid/java/lib/geronimo-jta_1.1_spec-1.1.1.jar (added) and qpid/trunk/qpid/java/lib/geronimo-jta_1.1_spec-1.1.1.jar
Sun Dec 18 05:09:07 2011 differ

Added: qpid/trunk/qpid/java/lib/geronimo-kernel-2.2.1.jar
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/lib/geronimo-kernel-2.2.1.jar?rev=1220336&view=auto
==============================================================================
Files qpid/trunk/qpid/java/lib/geronimo-kernel-2.2.1.jar (added) and qpid/trunk/qpid/java/lib/geronimo-kernel-2.2.1.jar
Sun Dec 18 05:09:07 2011 differ



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message