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

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Wed Jun 16 15:15:46 EDT 2010


Author: salaboy21
Date: 2010-06-16 15:15:45 -0400 (Wed, 16 Jun 2010)
New Revision: 33527

Modified:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/DirectoryInstance.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/ExecutionEnvironment.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/GridTopology.java
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/TaskServerInstance.java
Log:
addding getters dir, ee y tsi

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/DirectoryInstance.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/DirectoryInstance.java	2010-06-16 18:20:42 UTC (rev 33526)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/DirectoryInstance.java	2010-06-16 19:15:45 UTC (rev 33527)
@@ -1,30 +1,41 @@
 package org.drools.grid.services;
 
 import java.rmi.RemoteException;
+import java.util.List;
 import org.drools.grid.DirectoryNodeService;
 import org.drools.grid.GenericConnection;
+import org.drools.grid.strategies.DirectoryServiceSelectionStrategy;
 
 /**
  * @author salaboy
  */
-public class DirectoryInstance extends GridResource{
+public class DirectoryInstance extends GridResource {
 
     public DirectoryInstance(String name, GenericProvider provider) {
         super(name, provider);
-        
+
     }
 
     public DirectoryNodeService getDirectoryService() throws RemoteException {
         GenericConnection connection = getConnector().getConnection();
         DirectoryNodeService directory = connection.getDirectoryNode();
-        if(directory.connect()){
+        if (directory.connect()) {
             return directory;
         }
         return null;
     }
 
-    
+    public DirectoryNodeService getDirectoryService(DirectoryServiceSelectionStrategy strategy) throws RemoteException {
+        GenericConnection connection = getConnector().getConnection();
+        DirectoryNodeService directory = connection.getDirectoryNode(strategy);
+        if (directory.connect()) {
+            return directory;
+        }
+        return null;
+    }
 
-
-
+    public List<DirectoryNodeService> getDirectoryServices() throws RemoteException {
+        GenericConnection connection = getConnector().getConnection();
+        return connection.getDirectories();
+    }
 }

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/ExecutionEnvironment.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/ExecutionEnvironment.java	2010-06-16 18:20:42 UTC (rev 33526)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/ExecutionEnvironment.java	2010-06-16 19:15:45 UTC (rev 33527)
@@ -17,8 +17,10 @@
 
 package org.drools.grid.services;
 
+import java.util.List;
 import org.drools.grid.ExecutionNode;
 import org.drools.grid.GenericConnection;
+import org.drools.grid.strategies.NodeSelectionStrategy;
 import org.drools.grid.strategies.ReturnAlwaysTheFirstSelectionStrategy;
 
 /**
@@ -36,4 +38,15 @@
         return connection.getExecutionNode(new ReturnAlwaysTheFirstSelectionStrategy(connection));
     }
 
+    public ExecutionNode getExecutionNode(NodeSelectionStrategy strategy) {
+        GenericConnection connection = getConnector().getConnection();
+        return connection.getExecutionNode(strategy);
+    }
+
+    public List<ExecutionNode> getExecutionNodes(){
+        GenericConnection connection = getConnector().getConnection();
+        return connection.getExecutionNodes();
+        
+    }
+
 }

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/GridTopology.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/GridTopology.java	2010-06-16 18:20:42 UTC (rev 33526)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/GridTopology.java	2010-06-16 19:15:45 UTC (rev 33527)
@@ -33,18 +33,8 @@
 
     }
 
-//    public void registerGridResource(String name, GenericProvider provider) throws RemoteException {
-//
-//        GridResource resource = provider.getGridResource(name);
-//        GenericNodeConnector connector = resource.getConnector();
-//        GenericConnection connection = connector.getConnection();
-//        connection.addExecutionNode(connector);
-//        connections.put(name, connection);
-//        registerGridResourceInCurrentDirectories(name, provider.getId());
-//        resources.put(name, resource);
-//
-//    }
 
+
     public void registerExecutionEnvironment(String name, GenericProvider provider) throws RemoteException{
         //Create the executionEnvironment using the provider
         ExecutionEnvironment environment = new ExecutionEnvironment(name, provider);
@@ -92,11 +82,6 @@
     }
     
 
-    public static GridResource lookup(String name) {
-        //black magic
-        return null;
-    }
-
    
 
     

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/TaskServerInstance.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/TaskServerInstance.java	2010-06-16 18:20:42 UTC (rev 33526)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-services/src/main/java/org/drools/grid/services/TaskServerInstance.java	2010-06-16 19:15:45 UTC (rev 33527)
@@ -1,7 +1,9 @@
 package org.drools.grid.services;
 
+import java.util.List;
 import org.drools.grid.services.strategies.ReturnFirstHumanTaskServiceSelectionStrategy;
 import org.drools.grid.GenericConnection;
+import org.drools.grid.strategies.HumanTaskServiceSelectionStrategy;
 import org.drools.grid.task.HumanTaskService;
 /**
  * @author salaboy
@@ -22,8 +24,20 @@
         return null;
     }
 
-    
+     public HumanTaskService getTaskClient(HumanTaskServiceSelectionStrategy strategy) {
+        GenericConnection connection = getConnector().getConnection();
+        HumanTaskService htService = (HumanTaskService) connection.getTaskService(strategy);
+        if(htService.connect()){
+            return htService;
+        }
+        return null;
+    }
 
+    public List<HumanTaskService> getTaskClients() {
+        GenericConnection connection = getConnector().getConnection();
+        (HumanTaskService) connection.getTaskServices();
+        return 
+    }
 
 
 }



More information about the jboss-svn-commits mailing list