1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
/*
* 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
}
|
