[jboss-svn-commits] JBL Code SVN: r23812 - in labs/jbossrules/trunk/drools-process/drools-process-task/src: test/java/org/drools/process/workitem/wsht and 1 other directory.

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

Author: KrisVerlaenen
Date: 2008-11-10 20:04:09 -0500 (Mon, 10 Nov 2008)
New Revision: 23812

Modified:
   labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/process/workitem/wsht/WSHumanTaskHandler.java
   labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/WSHumanTaskHandlerTest.java
Log:
JBRULES-1834: Data for Tasks
 - added data to task + modified life cycle methods

Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/process/workitem/wsht/WSHumanTaskHandler.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/process/workitem/wsht/WSHumanTaskHandler.java	2008-11-11 00:57:07 UTC (rev 23811)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/main/java/org/drools/process/workitem/wsht/WSHumanTaskHandler.java	2008-11-11 01:04:09 UTC (rev 23812)
@@ -1,5 +1,8 @@
 package org.drools.process.workitem.wsht;
 
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
 import java.net.InetSocketAddress;
 import java.net.SocketAddress;
 import java.util.ArrayList;
@@ -14,6 +17,7 @@
 import org.drools.runtime.process.WorkItem;
 import org.drools.runtime.process.WorkItemHandler;
 import org.drools.runtime.process.WorkItemManager;
+import org.drools.task.AccessType;
 import org.drools.task.I18NText;
 import org.drools.task.OrganizationalEntity;
 import org.drools.task.PeopleAssignments;
@@ -25,6 +29,7 @@
 import org.drools.task.event.TaskEventKey;
 import org.drools.task.event.TaskFailedEvent;
 import org.drools.task.event.TaskSkippedEvent;
+import org.drools.task.service.ContentData;
 import org.drools.task.service.MinaTaskClient;
 import org.drools.task.service.TaskClientHandler;
 import org.drools.task.service.TaskClientHandler.AddTaskResponseHandler;
@@ -103,10 +108,26 @@
 			task.setPeopleAssignments(assignments);
 		}
 		
+		ContentData content = null;
+		Object contentObject = workItem.getParameter("Content");
+		if (contentObject != null) {
+			ByteArrayOutputStream bos = new ByteArrayOutputStream();
+			ObjectOutputStream out;
+			try {
+				out = new ObjectOutputStream(bos);
+				out.writeObject(contentObject);
+				out.close();
+				content = new ContentData();
+				content.setContent(bos.toByteArray());
+				content.setAccessType(AccessType.Inline);
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+		}
 		TaskWorkItemAddTaskResponseHandler taskResponseHandler =
 			new TaskWorkItemAddTaskResponseHandler(this.client, this.managers,
 				this.idMapping, manager, workItem.getId());
-		client.addTask(task, taskResponseHandler);
+		client.addTask(task, content, taskResponseHandler);
 	}
 	
 	public void dispose() {

Modified: labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/WSHumanTaskHandlerTest.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/WSHumanTaskHandlerTest.java	2008-11-11 00:57:07 UTC (rev 23811)
+++ labs/jbossrules/trunk/drools-process/drools-process-task/src/test/java/org/drools/process/workitem/wsht/WSHumanTaskHandlerTest.java	2008-11-11 01:04:09 UTC (rev 23812)
@@ -78,7 +78,7 @@
 		
 		System.out.println("Completing task " + task.getId());
 		operationResponseHandler = new BlockingTaskOperationResponseHandler();
-		client.complete(task.getId(), "Darth Vader", operationResponseHandler);
+		client.complete(task.getId(), "Darth Vader", null, operationResponseHandler);
 		operationResponseHandler.waitTillDone(5000);
 		System.out.println("Completed task " + task.getId());
 		
@@ -121,7 +121,7 @@
 		
 		System.out.println("Completing task " + task.getId());
 		operationResponseHandler = new BlockingTaskOperationResponseHandler();
-		client.complete(task.getId(), "Darth Vader", operationResponseHandler);
+		client.complete(task.getId(), "Darth Vader", null, operationResponseHandler);
 		operationResponseHandler.waitTillDone(5000);
 		System.out.println("Completed task " + task.getId());
 		
@@ -159,7 +159,7 @@
 		
 		System.out.println("Failing task " + task.getId());
 		operationResponseHandler = new BlockingTaskOperationResponseHandler();
-		client.fail(task.getId(), "Darth Vader", operationResponseHandler);
+		client.fail(task.getId(), "Darth Vader", null, operationResponseHandler);
 		operationResponseHandler.waitTillDone(5000);
 		System.out.println("Failed task " + task.getId());