User: pra
Date: 01/02/28 01:25:47
Modified: src/main/org/jboss/jms/jndi JBossMQProvider.java
JMSProviderLoaderMBean.java
Log:
MDB deployment descriptor now follows the latest EJB2.0 DTD; code clean up done;
message receipt now allways transacted
Revision Changes Path
1.2 +25 -4 jboss/src/main/org/jboss/jms/jndi/JBossMQProvider.java
Index: JBossMQProvider.java
===================================================================
RCS file:
/products/cvs/ejboss/jboss/src/main/org/jboss/jms/jndi/JBossMQProvider.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- JBossMQProvider.java 2001/02/02 04:35:49 1.1
+++ JBossMQProvider.java 2001/02/28 09:25:46 1.2
@@ -17,6 +17,8 @@
*/
package org.jboss.jms.jndi;
+import java.util.Hashtable;
+
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
@@ -33,20 +35,39 @@
public class JBossMQProvider implements JMSProviderAdapter, java.io.Serializable{
public static final String TOPIC_CONNECTION_FACTORY="XATopicConnectionFactory";
public static final String QUEUE_CONNECTION_FACTORY="XAQueueConnectionFactory";
-
+ public static final String INITIAL_CONTEXT_FACTORY =
"org.jnp.interfaces.NamingContextFactory";
+ public static final String URL_PKG_PREFIXES = "org.jboss.naming";
+ private static final String SECURITY_MANAGER="java.naming.rmi.security.manager";
+
+ private String hasJndiSecurityManager = "yes";
private String name;
private String url;
public JBossMQProvider() {
}
- public void setProviderUrl(String url) {this.url = url;}
+ public void setProviderUrl(String url) {
+ this.url = url;
+
+ }
public String getProviderUrl() { return url; }
public void setName(String name) {this.name = name;}
public String getName() {return name;}
public Context getInitialContext() throws NamingException {
- return new InitialContext();//Only for Jboss embedded now
-
+ Context ctx = null;
+ if (url == null) {
+ // Use default
+ ctx = new InitialContext();//Only for Jboss embedded now
+ } else {
+ //Try another location
+ Hashtable props = new Hashtable();
+ props.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);
+ props.put(Context.PROVIDER_URL, url);
+ props.put(SECURITY_MANAGER, hasJndiSecurityManager);
+ props.put(Context.URL_PKG_PREFIXES, URL_PKG_PREFIXES);
+ ctx = new InitialContext(props);
+ }
+ return ctx;
}
public String getTopicFactoryName(){return TOPIC_CONNECTION_FACTORY;}
public String getQueueFactoryName(){return QUEUE_CONNECTION_FACTORY;}
1.3 +4 -0 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.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- JMSProviderLoaderMBean.java 2000/12/07 16:19:29 1.2
+++ JMSProviderLoaderMBean.java 2001/02/28 09:25:46 1.3
@@ -40,5 +40,9 @@
public void setProviderAdapterClass(String clazz);
public String getProviderAdapterClass();
+
+ public void setProviderUrl(String url);
+
+ public String getProviderUrl();
}
