[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