User: chirino
Date: 01/05/21 21:54:37
Modified: src/main/org/jbossmq/server InvocationLayerFactory.java
StartServer.java
Log:
Revision Changes Path
1.3 +16 -4 jbossmq/src/main/org/jbossmq/server/InvocationLayerFactory.java
Index: InvocationLayerFactory.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/InvocationLayerFactory.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- InvocationLayerFactory.java 2001/03/02 01:13:01 1.2
+++ InvocationLayerFactory.java 2001/05/22 04:54:36 1.3
@@ -39,13 +39,14 @@
import org.jbossmq.SpyXAQueueConnectionFactory;
import org.jbossmq.SpyDistributedConnection;
+import org.jbossmq.xml.XElement;
+
public class InvocationLayerFactory
{
- // Set these attributes before the createObjects() call
- String connectionReceiverClassName;
+
+
- String distributedJMSServerClassName;
// These will be set after the createObjects() call
DistributedJMSServerSetup distributedJMSServerSetup;
@@ -56,13 +57,16 @@
public void createObjects(JMSServer s) throws Exception
{
+ String distributedJMSServerClassName = config.getField("ServerClass");
+ String connectionReceiverClassName = config.getField("ReceiverClass");
+
//Get the Topic properties
if (distributedJMSServerClassName == null ||
connectionReceiverClassName==null ) {
throw new RuntimeException("Missing configuration parameters");
}
distributedJMSServerSetup =
(DistributedJMSServerSetup)Class.forName(distributedJMSServerClassName).newInstance();
- distributedJMSServerSetup.setServer(s);
+ distributedJMSServerSetup.init(s, config);
distributedJMSServer = distributedJMSServerSetup.createClient();
//Create the distributedTopicConnectionFactory object
@@ -79,4 +83,12 @@
SpyXAQueueConnectionFactory spyXAQueueConnectionFactory;
SpyXATopicConnectionFactory spyXATopicConnectionFactory;
+ // Set these attributes before the createObjects() call
+ XElement config;
+
+ /**
+ */
+ public InvocationLayerFactory(XElement c) {
+ config = c;
+ }
}
1.4 +2 -5 jbossmq/src/main/org/jbossmq/server/StartServer.java
Index: StartServer.java
===================================================================
RCS file: /cvsroot/jboss/jbossmq/src/main/org/jbossmq/server/StartServer.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- StartServer.java 2001/05/15 07:16:48 1.3
+++ StartServer.java 2001/05/22 04:54:37 1.4
@@ -48,7 +48,7 @@
* @author Vincent Sheffer ([EMAIL PROTECTED])
* @author Hiram Chirino ([EMAIL PROTECTED])
*
- * @version $Revision: 1.3 $
+ * @version $Revision: 1.4 $
*/
public class StartServer implements Runnable
{
@@ -224,10 +224,7 @@
String xaQueueConnectionFactoryJNDI =
element.getField("XAQueueConnectionFactoryJNDI");
//Set up the transports for the server
- InvocationLayerFactory invocationLayerFactory= new
InvocationLayerFactory();
- invocationLayerFactory.distributedJMSServerClassName =
element.getField("ServerClass");
- invocationLayerFactory.connectionReceiverClassName =
element.getField("ReceiverClass");
-
+ InvocationLayerFactory invocationLayerFactory= new
InvocationLayerFactory(element);
invocationLayerFactory.createObjects(theServer);
registerService(invocationLayerFactory.distributedJMSServerSetup,
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
