[jboss-svn-commits] JBL Code SVN: r33649 - labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-api/src/main/java/org/drools/grid.

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

Author: salaboy21
Date: 2010-06-25 15:26:15 -0400 (Fri, 25 Jun 2010)
New Revision: 33649

Modified:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-api/src/main/java/org/drools/grid/GridConnection.java
Log:
adding getExecutionNodes implementation

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-api/src/main/java/org/drools/grid/GridConnection.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-api/src/main/java/org/drools/grid/GridConnection.java	2010-06-25 18:51:35 UTC (rev 33648)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-api/src/main/java/org/drools/grid/GridConnection.java	2010-06-25 19:26:15 UTC (rev 33649)
@@ -140,17 +140,21 @@
 
     public List<ExecutionNode> getExecutionNodes() throws ConnectorException {
         List<ExecutionNode> executionNodes = new ArrayList<ExecutionNode>();
-//        for (GenericNodeConnector connector : executionNodeConnectors) {
-//            ExecutionNode node = null;
-//            connector.connect();
-//            node = new ExecutionNode();
-//            node.set(KnowledgeBuilderFactoryService.class, new KnowledgeBuilderProviderRemoteClient(connector));
-//            node.set(KnowledgeBaseFactoryService.class, new KnowledgeBaseProviderRemoteClient(connector));
-//            node.set(DirectoryLookupFactoryService.class, new DirectoryLookupProviderRemoteClient(connector, this));
-//            if (node != null) {
-//                executionNodes.add(node);
-//            }
-//        }
+        for (GenericNodeConnector connector : executionNodeConnectors) {
+             NodeConnectionType type;
+            try {
+                type = connector.getNodeConnectionType();
+                System.out.println(">>>>>>>> Type = " + type);
+                connector.connect();
+
+                type.setConnector(connector);
+                type.setConnection(this);
+                type.init();
+                executionNodes.add(NodeFactory.newExecutionNode(type));
+            } catch (RemoteException ex) {
+                Logger.getLogger(GridConnection.class.getName()).log(Level.SEVERE, null, ex);
+            }
+         }
         return executionNodes;
     }