[jboss-remoting-commits] JBoss Remoting SVN: r4300 - remoting2/branches/2.2/src/main/org/jboss/remoting/transport.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2008-06-19 21:35:20 -0400 (Thu, 19 Jun 2008)
New Revision: 4300

Modified:
   remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java
Log:
JBREM-962: Added ability to read <repositories> element from xml config file.

Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java
===================================================================
--- remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java	2008-06-20 01:33:33 UTC (rev 4299)
+++ remoting2/branches/2.2/src/main/org/jboss/remoting/transport/Connector.java	2008-06-20 01:35:20 UTC (rev 4300)
@@ -44,8 +44,10 @@
 import javax.net.ServerSocketFactory;
 import javax.net.SocketFactory;
 import java.net.InetAddress;
+import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.Iterator;
+import java.util.List;
 import java.util.Map;
 import java.util.StringTokenizer;
 
@@ -463,7 +465,8 @@
       // if loaderLocator is null, then probably not defined to have loader service (i.e. no loader port specified)
       if (loaderLocator != null)
       {
-         marshallerLoader = MarshallLoaderFactory.createMarshallLoader(loaderLocator);
+         List repositories = getLoaderRepositories();
+         marshallerLoader = MarshallLoaderFactory.createMarshallLoader(loaderLocator, repositories, server);
       }
       return marshallerLoader;
    }
@@ -628,6 +631,41 @@
       }
    }
 
+   private List getLoaderRepositories()
+   {
+      if (xml == null)
+      {
+         return null;
+      }
+
+      NodeList repositoryNodes = xml.getElementsByTagName("repository");
+      if (repositoryNodes.getLength() == 0)
+      {
+         return null;
+      }
+      
+      List repositories = new ArrayList();
+      for (int i = 0; i < repositoryNodes.getLength(); i++)
+      {
+         Node node = repositoryNodes.item(i);
+         String repositoryName = node.getFirstChild().getNodeValue();
+
+         try
+         {
+            ObjectName objName = new ObjectName(repositoryName);
+            repositories.add(objName);
+            log.info("repository: " + repositoryName);
+         }
+         catch (MalformedObjectNameException e)
+         {
+            log.debug("repository name is not an object name: " + repositoryName);
+            continue;
+         }
+      }
+      
+      return repositories;
+   }
+   
    private ServerInvocationHandler createHandlerProxy(ObjectName objName)
    {
       ServerInvocationHandler handler;