summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java
diff options
context:
space:
mode:
authorlresende <lresende@13f79535-47bb-0310-9956-ffa450edef68>2013-10-07 22:23:21 +0000
committerlresende <lresende@13f79535-47bb-0310-9956-ffa450edef68>2013-10-07 22:23:21 +0000
commit5963a2d3d6860fe57afc138f095bf2d2eb5a7b80 (patch)
tree018d3d8c637e265b8292d34e5f7c11ca8ce11b7d /sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java
parent132aa8a77685ec92bc90c03f987650d275a7b639 (diff)
Official Tuscany 2.0.1 Release
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1530096 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java')
-rw-r--r--sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java113
1 files changed, 0 insertions, 113 deletions
diff --git a/sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java b/sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java
deleted file mode 100644
index f8c06058a0..0000000000
--- a/sca-java-2.x/tags/2.0.1-RC1/modules/binding-jms-runtime-activemq/src/main/java/org/apache/tuscany/sca/binding/jms/runtime/activemq/ActiveMQJMSResourceFactory.java
+++ /dev/null
@@ -1,113 +0,0 @@
-/*
- * 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.tuscany.sca.binding.jms.runtime.activemq;
-
-import java.util.Properties;
-
-import javax.naming.Context;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-
-import org.apache.activemq.jndi.ActiveMQInitialContextFactory;
-import org.apache.tuscany.sca.binding.jms.provider.JMSResourceFactoryImpl;
-import org.apache.tuscany.sca.extensibility.ClassLoaderContext;
-
-public class ActiveMQJMSResourceFactory extends JMSResourceFactoryImpl {
-
- public ActiveMQJMSResourceFactory(String connectionFactoryName,
- String responseConnectionFactoryName,
- String initialContextFactoryName,
- String jndiURL) {
- super(connectionFactoryName, responseConnectionFactoryName, initialContextFactoryName, jndiURL);
- }
-
- protected synchronized Context getInitialContext() throws NamingException {
- if (context == null) {
- Properties props = new Properties();
-
- if (initialContextFactoryName != null) {
- props.setProperty(Context.INITIAL_CONTEXT_FACTORY, initialContextFactoryName);
- }
- if (jndiURL != null) {
- props.setProperty(Context.PROVIDER_URL, jndiURL);
- }
-
- initJREEnvironment(props);
-
- try {
- // Load the JNDI InitialContext (will load the InitialContextFactory, if present)
- context = new InitialContext(props);
- if( context == null ) {
- throw new NamingException();
- } else if ( context.getEnvironment().get(InitialContext.INITIAL_CONTEXT_FACTORY) == null ) {
- throw new NamingException();
- } // end if
- } catch (NamingException e ) {
- context = getInitialContextOsgi( props );
- } // end try
- // In the case where the InitialContext fails, check whether performing an OSGi based load succeeds...
-
-
- }
- return context;
- } // end method getInitialContext
-
- static final String ACTIVEMQ_FACTORY = "org.apache.activemq.jndi.ActiveMQInitialContextFactory";
- private Context getInitialContextOsgi( Properties props ) throws NamingException {
- /**
- * For OSGi, need to provide access to the InitialContextFactory for the JMS provider that is going to be used.
- *
- * The situation is that the InitialContext constructor instantiates an instance of the InitialContextFactory by
- * calling "new" using the TCCL - thus there is a need to prepare the TCCL.
- * 03/12/2010 MJE - for the present, only worry about ActiveMQ - other providers can be added later
- * 10/12/2010 MJE - the following code attempts to get the classloader for the ActiveMQ initial context factory
- * it will fail if the ActiveMQ classes are not available in the runtime, but the code will still
- * execute (although under OSGi the new InitialContext() operation will fail to find a suitable
- * InitialContextFactory object...)
- */
-
- String contextFactoryName = (String)props.get(Context.INITIAL_CONTEXT_FACTORY);
-
- ClassLoader ActiveMQCl = null;
- try {
- if( contextFactoryName == null || ACTIVEMQ_FACTORY.equals(contextFactoryName) ) {
- ActiveMQCl = ActiveMQInitialContextFactory.class.getClassLoader();
- props.setProperty(Context.INITIAL_CONTEXT_FACTORY, ACTIVEMQ_FACTORY);
- if( props.getProperty(Context.PROVIDER_URL) == null ) {
- props.setProperty(Context.PROVIDER_URL, "vm://localhost?broker.persistent=false" );
- } // end if
- } // end if
- } catch (Exception e) {
- // Nothing to do in this case - the ActiveMQCl classloader will simply be null
- } // end try
-
- ClassLoader tccl = ClassLoaderContext.setContextClassLoader(JMSResourceFactoryImpl.class.getClassLoader(),
- ActiveMQCl,
- Thread.currentThread().getContextClassLoader() );
- try {
- // Load the JNDI InitialContext (will load the InitialContextFactory, if present)
- return new InitialContext(props);
- } finally {
- // Restore the TCCL if we changed it
- if( tccl != null ) Thread.currentThread().setContextClassLoader(tccl);
- } // end try
-
- } // end method getInitialContextOsgi
-}