[jboss-svn-commits] JBL Code SVN: r29597 - in labs/jbossrules/trunk: drools-api/src/main/java/org/drools/vsm and 4 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Oct 13 21:09:09 EDT 2009
Author: mark.proctor at jboss.com
Date: 2009-10-13 21:09:08 -0400 (Tue, 13 Oct 2009)
New Revision: 29597
Added:
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/vsm/
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineContextImpl.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineImpl.java
Removed:
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/distributed/
Modified:
labs/jbossrules/trunk/drools-api/src/main/java/org/drools/command/ContextManager.java
labs/jbossrules/trunk/drools-api/src/main/java/org/drools/vsm/ServiceManager.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/impl/KnowledgeCommandContext.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/impl/BatchExecutionImpl.java
labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/BasePipelineContext.java
Log:
JBRULES-2269 Virtual Service Manager
-now works for xstream
-split into remote/local
Modified: labs/jbossrules/trunk/drools-api/src/main/java/org/drools/command/ContextManager.java
===================================================================
--- labs/jbossrules/trunk/drools-api/src/main/java/org/drools/command/ContextManager.java 2009-10-13 19:11:13 UTC (rev 29596)
+++ labs/jbossrules/trunk/drools-api/src/main/java/org/drools/command/ContextManager.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -3,4 +3,6 @@
public interface ContextManager {
public Context getContext(String identifier);
+
+ public Context getDefaultContext();
}
Modified: labs/jbossrules/trunk/drools-api/src/main/java/org/drools/vsm/ServiceManager.java
===================================================================
--- labs/jbossrules/trunk/drools-api/src/main/java/org/drools/vsm/ServiceManager.java 2009-10-13 19:11:13 UTC (rev 29596)
+++ labs/jbossrules/trunk/drools-api/src/main/java/org/drools/vsm/ServiceManager.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -9,7 +9,7 @@
import org.drools.runtime.CommandExecutor;
import org.drools.runtime.Environment;
-public interface ServiceManager {
+public interface ServiceManager extends CommandExecutor {
KnowledgeBuilderProvider getKnowledgeBuilderFactory();
KnowledgeBaseProvider getKnowledgeBaseFactory();
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/impl/KnowledgeCommandContext.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/impl/KnowledgeCommandContext.java 2009-10-13 19:11:13 UTC (rev 29596)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/impl/KnowledgeCommandContext.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -7,6 +7,7 @@
import org.drools.runtime.ExecutionResults;
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.runtime.impl.ExecutionResultImpl;
+import org.drools.runtime.pipeline.impl.ServiceManagerPipelineImpl;
import org.drools.vsm.ServiceManager;
public class KnowledgeCommandContext
@@ -45,6 +46,11 @@
public ExecutionResults getExecutionResults() {
return this.kresults;
}
+
+ public ServiceManager getServiceManager() {
+ return null;
+ // return this.context.get( ServiceManagerPipelineImpl )
+ }
public ContextManager getContextManager() {
return context.getContextManager();
Copied: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/vsm (from rev 29353, labs/jbossrules/trunk/drools-core/src/main/java/org/drools/command/distributed)
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/impl/BatchExecutionImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/impl/BatchExecutionImpl.java 2009-10-13 19:11:13 UTC (rev 29596)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/impl/BatchExecutionImpl.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -9,15 +9,22 @@
import org.drools.reteoo.ReteooWorkingMemory;
import org.drools.runtime.StatefulKnowledgeSession;
import org.drools.runtime.process.ProcessInstance;
+import org.drools.vsm.ServiceManager;
public class BatchExecutionImpl implements GenericCommand<Void> {
private List<GenericCommand> commands;
+
+ private String lookup;
public BatchExecutionImpl(List<GenericCommand> commands) {
- super();
this.commands = commands;
}
+
+ public BatchExecutionImpl(List<GenericCommand> commands, String lookup) {
+ this.commands = commands;
+ this.lookup = lookup;
+ }
public List<GenericCommand> getCommands() {
return commands;
Modified: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/BasePipelineContext.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/BasePipelineContext.java 2009-10-13 19:11:13 UTC (rev 29596)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/BasePipelineContext.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -29,6 +29,10 @@
public ClassLoader getClassLoader() {
return this.classLoader;
}
+
+ public void setClassLoader(ClassLoader classLoader) {
+ this.classLoader = classLoader;
+ }
public Map<String, Object> getProperties() {
return properties;
Added: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineContextImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineContextImpl.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineContextImpl.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -0,0 +1,44 @@
+package org.drools.runtime.pipeline.impl;
+
+import org.drools.runtime.CommandExecutor;
+import org.drools.runtime.StatelessKnowledgeSession;
+import org.drools.runtime.pipeline.ResultHandler;
+import org.drools.runtime.pipeline.StatelessKnowledgeSessionPipelineContext;
+import org.drools.vsm.ServiceManager;
+
+public class ServiceManagerPipelineContextImpl extends BasePipelineContext {
+
+ private ServiceManager serviceManager;
+
+ private CommandExecutor commandExecutor;
+
+ public ServiceManagerPipelineContextImpl(ServiceManager serviceManager,
+ ClassLoader classLoader) {
+ this( serviceManager,
+ classLoader,
+ null );
+ }
+
+ public ServiceManagerPipelineContextImpl(ServiceManager serviceManager,
+ ClassLoader classLoader,
+ ResultHandler resultHandler) {
+ super( classLoader,
+ resultHandler );
+ this.serviceManager = serviceManager;
+ }
+
+ public ServiceManager getServiceManager() {
+ return this.serviceManager;
+ }
+
+ public CommandExecutor getCommandExecutor() {
+ return this.commandExecutor;
+ }
+
+ public void setCommandExecutor(CommandExecutor commandExecutor) {
+ this.commandExecutor = commandExecutor;
+ }
+
+
+
+}
Added: labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineImpl.java
===================================================================
--- labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineImpl.java (rev 0)
+++ labs/jbossrules/trunk/drools-core/src/main/java/org/drools/runtime/pipeline/impl/ServiceManagerPipelineImpl.java 2009-10-14 01:09:08 UTC (rev 29597)
@@ -0,0 +1,32 @@
+package org.drools.runtime.pipeline.impl;
+
+import java.io.InputStream;
+import java.io.Reader;
+
+import org.drools.common.InternalRuleBase;
+import org.drools.impl.KnowledgeBaseImpl;
+import org.drools.io.Resource;
+import org.drools.runtime.StatefulKnowledgeSession;
+import org.drools.runtime.pipeline.Pipeline;
+import org.drools.runtime.pipeline.ResultHandler;
+import org.drools.runtime.rule.WorkingMemoryEntryPoint;
+import org.drools.vsm.ServiceManager;
+
+
+public class ServiceManagerPipelineImpl extends BaseEmitter
+ implements
+ Pipeline {
+ private ServiceManager sm;
+
+ public ServiceManagerPipelineImpl(ServiceManager sm) {
+ this.sm = sm;
+ }
+
+ public synchronized void insert(Object object,
+ ResultHandler resultHandler) {
+ emit( object,
+ new ServiceManagerPipelineContextImpl(this.sm, null, resultHandler ) );
+
+ }
+
+}
More information about the jboss-svn-commits
mailing list