User: oberg
Date: 00/12/07 08:19:30
Modified: src/main/org/jboss/jms/jndi JMSProviderLoader.java
JMSProviderLoaderMBean.java
Log:
Fixed JMS MBeans to work with new configuration scheme
Formatting of source
Revision Changes Path
1.2 +104 -88 jboss/src/main/org/jboss/jms/jndi/JMSProviderLoader.java
Index: JMSProviderLoader.java
===================================================================
RCS file:
/products/cvs/ejboss/jboss/src/main/org/jboss/jms/jndi/JMSProviderLoader.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JMSProviderLoader.java 2000/12/06 12:52:36 1.1
+++ JMSProviderLoader.java 2000/12/07 16:19:29 1.2
@@ -39,98 +39,114 @@
* @version
*/
-public class JMSProviderLoader extends ServiceMBeanSupport
- implements JMSProviderLoaderMBean {
- JMSProviderAdapter providerAdapter;
-
- public JMSProviderLoader(String name, String jmsProviderAdapterClass) {
- try {
- Class cls = Class.forName(jmsProviderAdapterClass);
- providerAdapter = (JMSProviderAdapter)cls.newInstance();
- } catch(Exception e) {
- Logger.exception(e);
- throw new RuntimeException("Unable to initialize ProviderAdapter
'"+name+"': "+e);
- }
- providerAdapter.setName(name);
-
- }
-
- public void setProviderUrl(String url) {
- providerAdapter.setProviderUrl(url);
- }
-
- public String getProviderUrl() {
- return providerAdapter.getProviderUrl();
- }
- public ObjectName getObjectName(MBeanServer parm1, ObjectName parm2) throws
javax.management.MalformedObjectNameException {
- return (parm2 == null) ? new
ObjectName(OBJECT_NAME+",name="+providerAdapter.getName()) : parm2;
- }
-
- public String getName() {
- return providerAdapter.getName();
- }
- public void startService() throws Exception {
-
- initializeAdapter();
- }
-
- public void stopService() {
- // Unbind from JNDI
- try {
- String name = providerAdapter.getName();
- new InitialContext().unbind("java:/"+name);
- log.log("JMA Provider Adapter "+name+" removed from JNDI");
- //source.close();
- //log.log("XA Connection pool "+name+" shut down");
- } catch (NamingException e) {
- // Ignore
- }
- }
-
- // Private -------------------------------------------------------
-
- private void initializeAdapter() throws NamingException {
- Context ctx = null;
- Object mgr = null;
-
- /*
- source.setTransactionManagerJNDIName("java:/TransactionManager");
- try {
- ctx = new InitialContext();
- mgr = ctx.lookup("java:/TransactionManager");
- } catch(NamingException e) {
- throw new IllegalStateException("Cannot start XA Connection Pool; there
is no TransactionManager in JNDI!");
- }
- source.initialize();
- */
-
- // Bind in JNDI
- bind(new InitialContext(), "java:/"+providerAdapter.getName(),
providerAdapter);
-
- log.log("JMS provider Adapter "+providerAdapter.getName()+" bound to
java:/"+providerAdapter.getName());
-
-
- }
-
- private void bind(Context ctx, String name, Object val) throws NamingException {
- // Bind val to name in ctx, and make sure that all intermediate contexts
exist
- Name n = ctx.getNameParser("").parse(name);
- while (n.size() > 1) {
- String ctxName = n.get(0);
- try {
- ctx = (Context)ctx.lookup(ctxName);
- } catch (NameNotFoundException e) {
- ctx = ctx.createSubcontext(ctxName);
- }
- n = n.getSuffix(1);
- }
+public class JMSProviderLoader
+ extends ServiceMBeanSupport
+ implements JMSProviderLoaderMBean
+{
+ JMSProviderAdapter providerAdapter;
+
+ String url;
+ String providerName;
+ String providerAdapterClass;
+
+ public void setProviderName(String name)
+ {
+ this.providerName = name;
+ }
+
+ public String getProviderName()
+ {
+ return providerName;
+ }
+
+ public void setProviderAdapterClass(String clazz)
+ {
+ providerAdapterClass = clazz;
+ }
+
+ public String getProviderAdapterClass()
+ {
+ return providerAdapterClass;
+ }
+
+ public void setProviderUrl(String url)
+ {
+ this.url = url;
+ }
+
+ public String getProviderUrl()
+ {
+ return url;
+ }
+ public ObjectName getObjectName(MBeanServer parm1, ObjectName parm2)
+ throws javax.management.MalformedObjectNameException
+ {
+ return (parm2 == null) ? new ObjectName(OBJECT_NAME) : parm2;
+ }
+
+ public String getName()
+ {
+ return providerName;
+ }
+
+ public void initService()
+ throws Exception
+ {
+ Class cls = Class.forName(providerAdapterClass);
+ providerAdapter = (JMSProviderAdapter)cls.newInstance();
+ providerAdapter.setName(providerName);
+ providerAdapter.setProviderUrl(url);
+ }
+
+ public void startService()
+ throws Exception
+ {
+ // Bind in JNDI
+ bind(new InitialContext(), "java:/"+providerAdapter.getName(),
providerAdapter);
+
+ log.log("JMS provider Adapter "+providerAdapter.getName()+" bound to
java:/"+providerAdapter.getName());
+ }
+
+ public void stopService()
+ {
+ // Unbind from JNDI
+ try {
+ String name = providerAdapter.getName();
+ new InitialContext().unbind("java:/"+name);
+ log.log("JMA Provider Adapter "+name+" removed from JNDI");
+ //source.close();
+ //log.log("XA Connection pool "+name+" shut down");
+ } catch (NamingException e)
+ {
+ // Ignore
+ }
+ }
+
+ // Private -------------------------------------------------------
+ private void bind(Context ctx, String name, Object val) throws NamingException
+ {
+ // Bind val to name in ctx, and make sure that all intermediate contexts exist
+ Name n = ctx.getNameParser("").parse(name);
+ while (n.size() > 1)
+ {
+ String ctxName = n.get(0);
+ try
+ {
+ ctx = (Context)ctx.lookup(ctxName);
+ } catch (NameNotFoundException e)
+ {
+ ctx = ctx.createSubcontext(ctxName);
+ }
+ n = n.getSuffix(1);
+ }
+
+ ctx.bind(n.get(0), val);
+ }
- ctx.bind(n.get(0), val);
- }
+}
-} // JMSProviderLoader
1.2 +12 -2 jboss/src/main/org/jboss/jms/jndi/JMSProviderLoaderMBean.java
Index: JMSProviderLoaderMBean.java
===================================================================
RCS file:
/products/cvs/ejboss/jboss/src/main/org/jboss/jms/jndi/JMSProviderLoaderMBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JMSProviderLoaderMBean.java 2000/12/06 12:52:36 1.1
+++ JMSProviderLoaderMBean.java 2000/12/07 16:19:29 1.2
@@ -28,7 +28,17 @@
* @version
*/
-public interface JMSProviderLoaderMBean extends ServiceMBean{
+public interface JMSProviderLoaderMBean
+ extends ServiceMBean
+{
public static final String OBJECT_NAME = ":service=JMSProviderLoader";
+
+ public void setProviderName(String name);
-} // JMSProviderLoaderMBean
+ public String getProviderName();
+
+ public void setProviderAdapterClass(String clazz);
+
+ public String getProviderAdapterClass();
+
+}
