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

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

Author: diegoll
Date: 2010-06-26 21:43:31 -0400 (Sat, 26 Jun 2010)
New Revision: 33666

Modified:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-guvnor/src/main/java/org/drools/repository/services/grid/TopologyAssetsServiceImpl.java
Log:
added provider processing

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-guvnor/src/main/java/org/drools/repository/services/grid/TopologyAssetsServiceImpl.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-guvnor/src/main/java/org/drools/repository/services/grid/TopologyAssetsServiceImpl.java	2010-06-26 20:41:37 UTC (rev 33665)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-guvnor/src/main/java/org/drools/repository/services/grid/TopologyAssetsServiceImpl.java	2010-06-27 01:43:31 UTC (rev 33666)
@@ -11,8 +11,11 @@
 import org.drools.grid.services.configuration.GenericProvider;
 import org.drools.grid.services.configuration.GridResourceInfo;
 import org.drools.grid.services.configuration.GridTopologyView;
+import org.drools.grid.services.configuration.MinaProvider;
 import org.drools.grid.services.configuration.TaskServerInstanceView;
 import org.drools.grid.services.configuration.GridResourceInfo.Status;
+import org.drools.grid.services.factory.GenericProviderContainerBuilder;
+import org.drools.grid.services.factory.GenericProviderContainerFactoryHelper;
 import org.drools.grid.services.factory.GridTopologyFactory;
 import org.drools.guvnor.client.explorer.grid.services.TopologyAssetsService;
 
@@ -51,7 +54,29 @@
 		
 		String executionEnvironmentName = executionEnvironmentView.getName();
 		ExecutionEnvironment executionEnvironment = gridTopology.getExecutionEnvironment(executionEnvironmentName);
-		ExecutionEnvironmentInfo info = new ExecutionEnvironmentInfo();
+
+		ExecutionEnvironmentInfo info = GenericProviderContainerFactoryHelper.doOnGenericProvider(executionEnvironmentView.getProvider(), new GenericProviderContainerBuilder<ExecutionEnvironmentInfo>() {
+
+			public ExecutionEnvironmentInfo onHornetQProvider() {
+				return null;
+			}
+
+			public ExecutionEnvironmentInfo onLocalProvider() {
+				throw new IllegalArgumentException("Cannot set information for local providers");
+			}
+
+			public ExecutionEnvironmentInfo onMinaProvider(MinaProvider provider) {
+				ExecutionEnvironmentInfo info = new ExecutionEnvironmentInfo();
+				info.setAddress(provider.getProviderAddress());
+				info.setPort(provider.getProviderPort());
+				return info;
+			}
+
+			public ExecutionEnvironmentInfo onRioProvider() {
+				return null;
+			}
+		});
+
 		try{
 			fillInfo(info, executionEnvironment);
 		} catch (ConnectorException ise){