[jboss-svn-commits] JBL Code SVN: r30799 - in labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src: main/java/org/drools/vsm/task and 2 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Dec 22 10:47:20 EST 2009
Author: lucazamador
Date: 2009-12-22 10:47:20 -0500 (Tue, 22 Dec 2009)
New Revision: 30799
Modified:
labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/mina/ClientGenericMessageReceiverImpl.java
labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/task/CommandBasedVSMWSHumanTaskHandler.java
labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/BaseTest.java
labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/CommandBasedVSMWSHumanTaskHandlerTest.java
labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/vsm/ServiceManagerTestBase.java
Log:
All process tasks test migrated.
Modified: labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/mina/ClientGenericMessageReceiverImpl.java
===================================================================
--- labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/mina/ClientGenericMessageReceiverImpl.java 2009-12-22 14:00:36 UTC (rev 30798)
+++ labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/mina/ClientGenericMessageReceiverImpl.java 2009-12-22 15:47:20 UTC (rev 30799)
@@ -7,6 +7,7 @@
import java.util.concurrent.ConcurrentHashMap;
import org.drools.SystemEventListener;
+import org.drools.task.service.Command;
import org.drools.vsm.ClientGenericMessageReceiver;
import org.drools.vsm.GenericIoWriter;
import org.drools.vsm.GenericMessageHandler;
@@ -50,7 +51,10 @@
if ( responseHandler != null ) {
Object payload = msg.getPayload();
- if ( payload != null && payload instanceof RuntimeException ) {
+ if (payload instanceof Command && ((Command)msg.getPayload()).getArguments().size() > 0 &&
+ ((Command)msg.getPayload()).getArguments().get(0) instanceof RuntimeException)
+ payload = ((Command)msg.getPayload()).getArguments().get(0);
+ if (( payload != null && payload instanceof RuntimeException )) {
responseHandler.setError( (RuntimeException) payload );
} else {
responseHandler.receive( msg );
Modified: labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/task/CommandBasedVSMWSHumanTaskHandler.java
===================================================================
--- labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/task/CommandBasedVSMWSHumanTaskHandler.java 2009-12-22 14:00:36 UTC (rev 30798)
+++ labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/main/java/org/drools/vsm/task/CommandBasedVSMWSHumanTaskHandler.java 2009-12-22 15:47:20 UTC (rev 30799)
@@ -60,6 +60,7 @@
private HumanTaskServiceImpl client;
private KnowledgeRuntime session;
private Map<Long, Long> idMapping = new HashMap<Long, Long>();
+ private Map<Long, WorkItemManager> managers = new HashMap<Long, WorkItemManager>();
public CommandBasedVSMWSHumanTaskHandler(KnowledgeRuntime session) {
this.session = session;
@@ -183,8 +184,8 @@
e.printStackTrace();
}
}
- TaskWorkItemAddTaskMessageResponseHandler taskResponseHandler =
- new TaskWorkItemAddTaskMessageResponseHandler(this.client, workItem.getId());
+ TaskWorkItemAddTaskMessageResponseHandler taskResponseHandler =
+ new TaskWorkItemAddTaskMessageResponseHandler(workItem.getId(), this.managers, idMapping, manager);
client.addTask(task, content, taskResponseHandler);
}
@@ -200,15 +201,27 @@
synchronized (idMapping) {
idMapping.remove(taskId);
}
+ synchronized (managers) {
+ managers.remove(taskId);
+ }
client.skip(taskId, "Administrator", null);
}
}
public class TaskWorkItemAddTaskMessageResponseHandler implements AddTaskMessageResponseHandler {
+
+ private Map<Long, WorkItemManager> managers;
+ private Map<Long, Long> idMapping;
+ private WorkItemManager manager;
private long workItemId;
- public TaskWorkItemAddTaskMessageResponseHandler(HumanTaskServiceImpl client, long workItemId) {
- this.workItemId = workItemId;
+ public TaskWorkItemAddTaskMessageResponseHandler(long workItemId,
+ Map<Long, WorkItemManager> managers, Map<Long, Long> idMapping,
+ WorkItemManager manager) {
+ this.workItemId = workItemId;
+ this.managers = managers;
+ this.idMapping = idMapping;
+ this.manager = manager;
}
public void execute(long taskId) {
@@ -219,13 +232,16 @@
Command command = (Command) message.getPayload();
Long taskId = (Long) command.getArguments().get(0);
- synchronized ( idMapping ) {
- idMapping.put(workItemId, taskId);
- }
+ synchronized ( managers ) {
+ managers.put(taskId, this.manager);
+ }
+ synchronized ( idMapping ) {
+ idMapping.put(workItemId, taskId);
+ }
System.out.println("Created task " + taskId + " for work item " + workItemId);
- EventKey key = new TaskEventKey(TaskCompletedEvent.class, taskId );
- TaskCompletedMessageHandler eventResponseHandler = new TaskCompletedMessageHandler(workItemId, taskId);
+ EventKey key = new TaskEventKey(TaskCompletedEvent.class, taskId);
+ TaskCompletedMessageHandler eventResponseHandler = new TaskCompletedMessageHandler(workItemId, taskId, managers);
client.registerForEvent( key, true, eventResponseHandler );
key = new TaskEventKey(TaskFailedEvent.class, taskId );
client.registerForEvent( key, true, eventResponseHandler );
@@ -242,10 +258,12 @@
private class TaskCompletedMessageHandler implements EventMessageResponseHandler {
private long workItemId;
private long taskId;
+ private final Map<Long, WorkItemManager> managers;
- public TaskCompletedMessageHandler(long workItemId, long taskId) {
+ public TaskCompletedMessageHandler(long workItemId, long taskId, Map<Long, WorkItemManager> managers) {
this.workItemId = workItemId;
this.taskId = taskId;
+ this.managers = managers;
}
public void execute(Payload payload) {
@@ -266,17 +284,32 @@
return;
}
if (event instanceof TaskCompletedEvent) {
- GetTaskMessageResponseHandler getTaskResponseHandler = new GetCompletedTaskMessageResponseHandler();
- client.getTask(taskId, getTaskResponseHandler);
+ synchronized ( this.managers ) {
+ WorkItemManager manager = this.managers.get(taskId);
+ if (manager != null) {
+ GetCompletedTaskMessageResponseHandler getTaskResponseHandler = new GetCompletedTaskMessageResponseHandler(manager);
+ client.getTask(taskId, getTaskResponseHandler);
+ }
+ }
} else {
- session.getWorkItemManager().abortWorkItem(workItemId);
+ synchronized ( this.managers ) {
+ WorkItemManager manager = this.managers.get(taskId);
+ if (manager != null)
+ manager.abortWorkItem(workItemId);
+ }
}
}
}
private class GetCompletedTaskMessageResponseHandler implements GetTaskMessageResponseHandler {
- public void setError(RuntimeException error) {
+ private WorkItemManager manager;
+
+ public GetCompletedTaskMessageResponseHandler(WorkItemManager manager) {
+ this.manager = manager;
+ }
+
+ public void setError(RuntimeException error) {
throw new UnsupportedOperationException("Not supported yet.");
}
@@ -290,10 +323,10 @@
long contentId = task.getTaskData().getOutputContentId();
if (contentId != -1) {
GetResultContentMessageResponseHandler getContentResponseHandler =
- new GetResultContentMessageResponseHandler(task, results);
+ new GetResultContentMessageResponseHandler(manager, task, results);
client.getContent(contentId, getContentResponseHandler);
} else {
- session.getWorkItemManager().completeWorkItem(workItemId, results);
+ manager.completeWorkItem(workItemId, results);
}
}
@@ -303,11 +336,14 @@
}
private class GetResultContentMessageResponseHandler implements GetContentMessageResponseHandler {
+
private Task task;
+ private final WorkItemManager manager;
private Map<String, Object> results;
- public GetResultContentMessageResponseHandler(Task task, Map<String, Object> results) {
- this.task = task;
+ public GetResultContentMessageResponseHandler(WorkItemManager manager, Task task, Map<String, Object> results) {
+ this.manager = manager;
+ this.task = task;
this.results = results;
}
@@ -316,7 +352,8 @@
}
public void receive(Message message) {
- Content content = (Content)message.getPayload();
+ Command cmd = (Command)message.getPayload();
+ Content content = (Content)cmd.getArguments().get(0);
ByteArrayInputStream bis = new ByteArrayInputStream(content.getContent());
ObjectInputStream in;
try {
@@ -332,7 +369,7 @@
}
}
}
- session.getWorkItemManager().completeWorkItem(task.getTaskData().getWorkItemId(), results);
+ manager.completeWorkItem(task.getTaskData().getWorkItemId(), results);
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
Modified: labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/BaseTest.java
===================================================================
--- labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/BaseTest.java 2009-12-22 14:00:36 UTC (rev 30798)
+++ labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/BaseTest.java 2009-12-22 15:47:20 UTC (rev 30799)
@@ -27,10 +27,10 @@
protected Map<String, User> users;
protected Map<String, Group> groups;
- protected TaskService taskService;
+ protected static TaskService taskService;
protected TaskServiceSession taskSession;
- protected void setUp() throws Exception {
+ public void setUp() throws Exception {
Properties conf = new Properties();
conf.setProperty("mail.smtp.host", "localhost");
conf.setProperty("mail.smtp.port", "2345");
Modified: labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/CommandBasedVSMWSHumanTaskHandlerTest.java
===================================================================
--- labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/CommandBasedVSMWSHumanTaskHandlerTest.java 2009-12-22 14:00:36 UTC (rev 30798)
+++ labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/task/CommandBasedVSMWSHumanTaskHandlerTest.java 2009-12-22 15:47:20 UTC (rev 30799)
@@ -2,6 +2,7 @@
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
+import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetSocketAddress;
@@ -14,6 +15,7 @@
import org.apache.mina.transport.socket.SocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
import org.apache.mina.transport.socket.nio.NioSocketConnector;
+import org.apache.tools.ant.taskdefs.Sleep;
import org.drools.KnowledgeBase;
import org.drools.KnowledgeBaseProvider;
import org.drools.SystemEventListenerFactory;
@@ -39,6 +41,8 @@
import org.drools.vsm.task.responseHandlers.BlockingGetTaskMessageResponseHandler;
import org.drools.vsm.task.responseHandlers.BlockingTaskOperationMessageResponseHandler;
import org.drools.vsm.task.responseHandlers.BlockingTaskSummaryMessageResponseHandler;
+import org.junit.Before;
+import org.junit.BeforeClass;
public class CommandBasedVSMWSHumanTaskHandlerTest extends BaseTest {
@@ -51,70 +55,70 @@
private ServiceManagerRemoteClient client;
private CommandBasedVSMWSHumanTaskHandler handler;
private HumanTaskServiceImpl humanTaskClient;
-
- @Override
- protected void setUp() throws Exception {
- super.setUp();
-
- SocketAddress address = new InetSocketAddress("127.0.0.1", 9123);
- ServiceManagerData serverData = new ServiceManagerData();
- // setup Server
- SocketAcceptor acceptor = new NioSocketAcceptor();
- acceptor.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener(),
- new GenericMessageHandlerImpl(serverData,
- SystemEventListenerFactory.getSystemEventListener())));
- this.server = new MinaAcceptor(acceptor, address);
- this.server.start();
- // End Execution Server
-
- // Human task Server configuration
- SocketAddress htAddress = new InetSocketAddress("127.0.0.1", 9124);
- SocketAcceptor htAcceptor = new NioSocketAcceptor();
-
- htAcceptor.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener(),
- new TaskServerMessageHandlerImpl(taskService,
- SystemEventListenerFactory.getSystemEventListener())));
- this.humanTaskServer = new MinaAcceptor(htAcceptor, htAddress);
- this.humanTaskServer.start();
-
- // End Human task Server configuration
-
- // setup the ht client
- NioSocketConnector htclientConnector = new NioSocketConnector();
- htclientConnector.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener()));
- GenericConnector htMinaClient = new MinaConnector("client ht",
- htclientConnector,
- htAddress,
- SystemEventListenerFactory.getSystemEventListener() );
-
- // setup the SM client
- NioSocketConnector clientConnector = new NioSocketConnector();
- clientConnector.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener()));
- GenericConnector minaClient = new MinaConnector("client SM",
- clientConnector,
- address,
- SystemEventListenerFactory.getSystemEventListener());
-
- // Service Manager client, that contains a list of service beside the execution Server, in this case the HumanTaskService
- List<GenericConnector> services = new ArrayList<GenericConnector>();
- services.add(htMinaClient);
- this.client = new ServiceManagerRemoteClient("client SM", minaClient, services);
-
- ((ServiceManagerRemoteClient) client).connect();
-
- HumanTaskServiceProvider humanTaskServiceFactory = this.client.getHumanTaskService();
+
+ public void setUp() throws Exception {
+ super.setUp();
+ SocketAddress address = new InetSocketAddress("127.0.0.1", 9123);
+ ServiceManagerData serverData = new ServiceManagerData();
+ // setup Server
+ SocketAcceptor acceptor = new NioSocketAcceptor();
+ acceptor.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener(),
+ new GenericMessageHandlerImpl(serverData,
+ SystemEventListenerFactory.getSystemEventListener())));
+ this.server = new MinaAcceptor(acceptor, address);
+ this.server.start();
+ // End Execution Server
+
+ // Human task Server configuration
+ SocketAddress htAddress = new InetSocketAddress("127.0.0.1", 9124);
+ SocketAcceptor htAcceptor = new NioSocketAcceptor();
+
+ htAcceptor.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener(),
+ new TaskServerMessageHandlerImpl(taskService,
+ SystemEventListenerFactory.getSystemEventListener())));
+ this.humanTaskServer = new MinaAcceptor(htAcceptor, htAddress);
+ this.humanTaskServer.start();
+
+ // End Human task Server configuration
+
+ // setup the ht client
+ NioSocketConnector htclientConnector = new NioSocketConnector();
+ htclientConnector.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener()));
+ GenericConnector htMinaClient = new MinaConnector("client ht",
+ htclientConnector,
+ htAddress,
+ SystemEventListenerFactory.getSystemEventListener() );
+
+ // setup the SM client
+ NioSocketConnector clientConnector = new NioSocketConnector();
+ clientConnector.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener()));
+ GenericConnector minaClient = new MinaConnector("client SM",
+ clientConnector,
+ address,
+ SystemEventListenerFactory.getSystemEventListener());
+
+ // Service Manager client, that contains a list of service beside the execution Server, in this case the HumanTaskService
+ List<GenericConnector> services = new ArrayList<GenericConnector>();
+ services.add(htMinaClient);
+ this.client = new ServiceManagerRemoteClient("client SM", minaClient, services);
+
+ ((ServiceManagerRemoteClient) client).connect();
+
+ HumanTaskServiceProvider humanTaskServiceFactory = this.client.getHumanTaskService();
this.humanTaskClient = (HumanTaskServiceImpl) humanTaskServiceFactory.newHumanTaskServiceClient();
-
+
KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
this.handler = new CommandBasedVSMWSHumanTaskHandler(kbase.newStatefulKnowledgeSession());
- }
-
+
+ }
+
protected void tearDown() throws Exception {
this.handler.dispose();
this.client.disconnect();
this.server.stop();
+ this.humanTaskServer.stop();
super.tearDown();
}
@@ -152,8 +156,7 @@
humanTaskClient.complete(task.getId(), "Darth Vader", null, operationResponseHandler);
operationResponseHandler.waitTillDone(15000);
System.out.println("Completed task " + task.getId());
-
- assertTrue(manager.waitTillCompleted(MANAGER_COMPLETION_WAIT_TIME));
+ assertTrue(manager.waitTillCompleted(DEFAULT_WAIT_TIME));
}
public void testTaskMultipleActors() throws Exception {
@@ -227,9 +230,12 @@
BlockingTaskOperationMessageResponseHandler operationResponseHandler = new BlockingTaskOperationMessageResponseHandler();
humanTaskClient.claim(taskSummary.getId(), "Darth Vader", operationResponseHandler);
PermissionDeniedException denied = null;
+ System.out.println("1");
try {
operationResponseHandler.waitTillDone(DEFAULT_WAIT_TIME);
+ System.out.println("2");
} catch (PermissionDeniedException e) {
+ System.out.println("EXCEPTION: " + e);
denied = e;
}
Modified: labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/vsm/ServiceManagerTestBase.java
===================================================================
--- labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/vsm/ServiceManagerTestBase.java 2009-12-22 14:00:36 UTC (rev 30798)
+++ labs/jbossrules/branches/human-task-vsm_lucaz-salaboy/drools-vsm/src/test/java/org/drools/vsm/ServiceManagerTestBase.java 2009-12-22 15:47:20 UTC (rev 30799)
@@ -29,165 +29,165 @@
private HumanTaskService htClient;
private ProcessInstance processInstance;
- public void testFireAllRules() throws Exception {
- String str = "";
- str += "package org.drools \n";
- str += "global java.util.List list \n";
- str += "rule rule1 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello1!!!\" ); \n";
- str += "end \n";
- str += "rule rule2 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello2!!!\" ); \n";
- str += "end \n";
+// public void testFireAllRules() throws Exception {
+// String str = "";
+// str += "package org.drools \n";
+// str += "global java.util.List list \n";
+// str += "rule rule1 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello1!!!\" ); \n";
+// str += "end \n";
+// str += "rule rule2 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello2!!!\" ); \n";
+// str += "end \n";
+//
+// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+// ResourceType.DRL );
+//
+// if ( kbuilder.hasErrors() ) {
+// System.out.println( "Errors: " + kbuilder.getErrors() );
+// }
+//
+// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+//
+// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+//
+// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+// int fired = ksession.fireAllRules();
+// assertEquals( 2,
+// fired );
+// }
+//
+// public void testExecute() throws Exception {
+// String str = "";
+// str += "package org.drools \n";
+// str += "global java.util.List list \n";
+// str += "rule rule1 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello1!!!\" ); \n";
+// str += "end \n";
+// str += "rule rule2 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello2!!!\" ); \n";
+// str += "end \n";
+//
+// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+// ResourceType.DRL );
+//
+// if ( kbuilder.hasErrors() ) {
+// System.out.println( "Errors: " + kbuilder.getErrors() );
+// }
+//
+// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+//
+// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+//
+// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+//
+// ExecutionResults results = ksession.execute( new FireAllRulesCommand( "fired" ) );
+//
+// assertEquals( 2,
+// (int) (Integer) results.getValue( "fired" ) );
+// }
+//
+// public void testNamedService() throws Exception {
+// String str = "";
+// str += "package org.drools \n";
+// str += "global java.util.List list \n";
+// str += "rule rule1 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello1!!!\" ); \n";
+// str += "end \n";
+// str += "rule rule2 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello2!!!\" ); \n";
+// str += "end \n";
+//
+// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+// ResourceType.DRL );
+//
+// if ( kbuilder.hasErrors() ) {
+// System.out.println( "Errors: " + kbuilder.getErrors() );
+// }
+//
+// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+//
+// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+//
+// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+//
+// this.client.register( "ksession1",
+// ksession );
+//
+// ExecutionResults results = this.client.lookup( "ksession1" ).execute( new FireAllRulesCommand( "fired" ) );
+//
+// assertEquals( 2,
+// (int) (Integer) results.getValue( "fired" ) );
+// }
+//
+// public void testVsmPipeline() throws Exception {
+// String str = "";
+// str += "package org.drools \n";
+// str += "global java.util.List list \n";
+// str += "rule rule1 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello1!!!\" ); \n";
+// str += "end \n";
+// str += "rule rule2 \n";
+// str += " dialect \"java\" \n";
+// str += "when \n";
+// str += "then \n";
+// str += " System.out.println( \"hello2!!!\" ); \n";
+// str += "end \n";
+//
+// KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
+// KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
+// kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
+// ResourceType.DRL );
+//
+// if ( kbuilder.hasErrors() ) {
+// System.out.println( "Errors: " + kbuilder.getErrors() );
+// }
+//
+// KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
+// KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
+//
+// kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
+//
+// StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
+//
+// this.client.register( "ksession1",
+// ksession );
+//
+// // ExecutionResults results = this.client.lookup( "ksession1" ).execute( new FireAllRulesCommand( "fired" ) );
+// //
+// // assertEquals( 2, (int ) ( Integer) results.getValue( "fired" ) );
+// }
- KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
- KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
- kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
- ResourceType.DRL );
-
- if ( kbuilder.hasErrors() ) {
- System.out.println( "Errors: " + kbuilder.getErrors() );
- }
-
- KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
- KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-
- kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-
- StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
- int fired = ksession.fireAllRules();
- assertEquals( 2,
- fired );
- }
-
- public void testExecute() throws Exception {
- String str = "";
- str += "package org.drools \n";
- str += "global java.util.List list \n";
- str += "rule rule1 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello1!!!\" ); \n";
- str += "end \n";
- str += "rule rule2 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello2!!!\" ); \n";
- str += "end \n";
-
- KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
- KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
- kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
- ResourceType.DRL );
-
- if ( kbuilder.hasErrors() ) {
- System.out.println( "Errors: " + kbuilder.getErrors() );
- }
-
- KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
- KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-
- kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-
- StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
-
- ExecutionResults results = ksession.execute( new FireAllRulesCommand( "fired" ) );
-
- assertEquals( 2,
- (int) (Integer) results.getValue( "fired" ) );
- }
-
- public void testNamedService() throws Exception {
- String str = "";
- str += "package org.drools \n";
- str += "global java.util.List list \n";
- str += "rule rule1 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello1!!!\" ); \n";
- str += "end \n";
- str += "rule rule2 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello2!!!\" ); \n";
- str += "end \n";
-
- KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
- KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
- kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
- ResourceType.DRL );
-
- if ( kbuilder.hasErrors() ) {
- System.out.println( "Errors: " + kbuilder.getErrors() );
- }
-
- KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
- KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-
- kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-
- StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
-
- this.client.register( "ksession1",
- ksession );
-
- ExecutionResults results = this.client.lookup( "ksession1" ).execute( new FireAllRulesCommand( "fired" ) );
-
- assertEquals( 2,
- (int) (Integer) results.getValue( "fired" ) );
- }
-
- public void testVsmPipeline() throws Exception {
- String str = "";
- str += "package org.drools \n";
- str += "global java.util.List list \n";
- str += "rule rule1 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello1!!!\" ); \n";
- str += "end \n";
- str += "rule rule2 \n";
- str += " dialect \"java\" \n";
- str += "when \n";
- str += "then \n";
- str += " System.out.println( \"hello2!!!\" ); \n";
- str += "end \n";
-
- KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
- KnowledgeBuilder kbuilder = kbuilderFactory.newKnowledgeBuilder();
- kbuilder.add( ResourceFactory.newByteArrayResource( str.getBytes() ),
- ResourceType.DRL );
-
- if ( kbuilder.hasErrors() ) {
- System.out.println( "Errors: " + kbuilder.getErrors() );
- }
-
- KnowledgeBaseProvider kbaseFactory = this.client.getKnowledgeBaseFactory();
- KnowledgeBase kbase = kbaseFactory.newKnowledgeBase();
-
- kbase.addKnowledgePackages( kbuilder.getKnowledgePackages() );
-
- StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
-
- this.client.register( "ksession1",
- ksession );
-
- // ExecutionResults results = this.client.lookup( "ksession1" ).execute( new FireAllRulesCommand( "fired" ) );
- //
- // assertEquals( 2, (int ) ( Integer) results.getValue( "fired" ) );
- }
-
public void testHumanTasks() throws Exception {
KnowledgeBuilderProvider kbuilderFactory = this.client.getKnowledgeBuilderFactory();
More information about the jboss-svn-commits
mailing list