[jboss-svn-commits] JBL Code SVN: r32119 - in labs/jbossrules/trunk/drools-process: drools-gwt-form/src/main/java/org/drools/integration/console/forms and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Mar 16 14:03:02 EDT 2010
Author: KrisVerlaenen
Date: 2010-03-16 14:03:01 -0400 (Tue, 16 Mar 2010)
New Revision: 32119
Modified:
labs/jbossrules/trunk/drools-process/drools-gwt-console/src/main/java/org/drools/integration/console/DroolsFlowTaskManagement.java
labs/jbossrules/trunk/drools-process/drools-gwt-form/src/main/java/org/drools/integration/console/forms/ProcessFormDispatcher.java
labs/jbossrules/trunk/drools-process/drools-gwt-graph/src/main/resources/com.sample.evaluation.png
Log:
JBRULES-2447: Upgrade gwt-console to 2.0.1
- fixing minor issues
Modified: labs/jbossrules/trunk/drools-process/drools-gwt-console/src/main/java/org/drools/integration/console/DroolsFlowTaskManagement.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-gwt-console/src/main/java/org/drools/integration/console/DroolsFlowTaskManagement.java 2010-03-16 17:24:13 UTC (rev 32118)
+++ labs/jbossrules/trunk/drools-process/drools-gwt-console/src/main/java/org/drools/integration/console/DroolsFlowTaskManagement.java 2010-03-16 18:03:01 UTC (rev 32119)
@@ -1,162 +1,151 @@
-package org.drools.integration.console;
-
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.ObjectOutputStream;
-import java.net.InetSocketAddress;
-import java.net.SocketAddress;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.mina.transport.socket.nio.NioSocketConnector;
-import org.drools.SystemEventListenerFactory;
-import org.drools.process.workitem.wsht.BlockingGetTaskResponseHandler;
-import org.drools.task.AccessType;
-import org.drools.task.Status;
-import org.drools.task.Task;
-import org.drools.task.query.TaskSummary;
-import org.drools.task.service.ContentData;
-import org.drools.task.service.MinaTaskClient;
-import org.drools.task.service.TaskClientHandler;
-import org.drools.task.service.responsehandlers.BlockingTaskOperationResponseHandler;
-import org.drools.task.service.responsehandlers.BlockingTaskSummaryResponseHandler;
-import org.jboss.bpm.console.client.model.TaskRef;
-import org.jboss.bpm.console.server.integration.TaskManagement;
-
-public class DroolsFlowTaskManagement implements TaskManagement {
-
- // TODO: make this configurable
- private String ipAddress = "127.0.0.1";
- private int port = 9123;
- private MinaTaskClient client;
-
- public void setConnection(String ipAddress, int port) {
- this.ipAddress = ipAddress;
- this.port = port;
- }
-
- public void connect() {
- if (client == null) {
- client = new MinaTaskClient(
- "org.drools.process.workitem.wsht.WSHumanTaskHandler",
- new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()));
- NioSocketConnector connector = new NioSocketConnector();
- SocketAddress address = new InetSocketAddress(ipAddress, port);
- boolean connected = client.connect(connector, address);
- if (!connected) {
- throw new IllegalArgumentException(
- "Could not connect task client");
- }
- }
- }
-
- public TaskRef getTaskById(long taskId) {
- connect();
- BlockingGetTaskResponseHandler responseHandler = new BlockingGetTaskResponseHandler();
- client.getTask(taskId, responseHandler);
- Task task = responseHandler.getTask();
- return DroolsFlowTransform.task(task);
- }
-
- public void assignTask(long taskId, String idRef, String userId) {
- // TODO
- if (userId == null) {
- System.err.println("assignTask: userId == null, using 'admin'");
- userId = "admin";
- }
- connect();
- BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
- if (idRef != null && idRef.equals(userId)) {
- client.claim(taskId, idRef, responseHandler);
- } else {
- client.delegate(taskId, userId, idRef, responseHandler);
- }
- responseHandler.waitTillDone(5000);
- }
-
- @SuppressWarnings("unchecked")
- public void completeTask(long taskId, Map data, String userId) {
- // TODO
- if (userId == null) {
- System.err.println("assignTask: userId == null, using 'admin'");
- userId = "admin";
- }
- connect();
- BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
- client.start(taskId, userId, responseHandler);
- responseHandler.waitTillDone(5000);
- responseHandler = new BlockingTaskOperationResponseHandler();
- ContentData contentData = null;
- if (data != null) {
- ByteArrayOutputStream bos = new ByteArrayOutputStream();
- ObjectOutputStream out;
- try {
- out = new ObjectOutputStream(bos);
- out.writeObject(data);
- out.close();
- contentData = new ContentData();
- contentData.setContent(bos.toByteArray());
- contentData.setAccessType(AccessType.Inline);
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- client.complete(taskId, userId, contentData, responseHandler);
- responseHandler.waitTillDone(5000);
- }
-
- @SuppressWarnings("unchecked")
- public void completeTask(long taskId, String outcome, Map data, String userId) {
- data.put("outcome", outcome);
- completeTask(taskId, data, userId);
- }
-
- public void releaseTask(long taskId, String userId) {
- // TODO
- if (userId == null) {
- System.err.println("assignTask: userId == null, using 'admin'");
- userId = "admin";
- }
- connect();
- BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
- client.release(taskId, userId, responseHandler);
- responseHandler.waitTillDone(5000);
- }
-
- public List<TaskRef> getAssignedTasks(String idRef) {
- connect();
- List<TaskRef> result = new ArrayList<TaskRef>();
- try {
- BlockingTaskSummaryResponseHandler responseHandler = new BlockingTaskSummaryResponseHandler();
- client.getTasksOwned(idRef, "en-UK", responseHandler);
- List<TaskSummary> tasks = responseHandler.getResults();
- for (TaskSummary task: tasks) {
- if (task.getStatus() == Status.Reserved) {
- result.add(DroolsFlowTransform.task(task));
- }
- }
- } catch (Throwable t) {
- t.printStackTrace();
- }
- return result;
- }
-
- public List<TaskRef> getUnassignedTasks(String idRef, String participationType) {
- // TODO participationType ?
- connect();
- List<TaskRef> result = new ArrayList<TaskRef>();
- try {
- BlockingTaskSummaryResponseHandler responseHandler = new BlockingTaskSummaryResponseHandler();
- client.getTasksAssignedAsPotentialOwner(idRef, "en-UK", responseHandler);
- List<TaskSummary> tasks = responseHandler.getResults();
- for (TaskSummary task: tasks) {
- result.add(DroolsFlowTransform.task(task));
- }
- } catch (Throwable t) {
- t.printStackTrace();
- }
- return result;
- }
-
-}
+package org.drools.integration.console;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.mina.transport.socket.nio.NioSocketConnector;
+import org.drools.SystemEventListenerFactory;
+import org.drools.process.workitem.wsht.BlockingGetTaskResponseHandler;
+import org.drools.task.AccessType;
+import org.drools.task.Status;
+import org.drools.task.Task;
+import org.drools.task.query.TaskSummary;
+import org.drools.task.service.ContentData;
+import org.drools.task.service.MinaTaskClient;
+import org.drools.task.service.TaskClientHandler;
+import org.drools.task.service.responsehandlers.BlockingTaskOperationResponseHandler;
+import org.drools.task.service.responsehandlers.BlockingTaskSummaryResponseHandler;
+import org.jboss.bpm.console.client.model.TaskRef;
+import org.jboss.bpm.console.server.integration.TaskManagement;
+
+public class DroolsFlowTaskManagement implements TaskManagement {
+
+ // TODO: make this configurable
+ private String ipAddress = "127.0.0.1";
+ private int port = 9123;
+ private MinaTaskClient client;
+
+ public void setConnection(String ipAddress, int port) {
+ this.ipAddress = ipAddress;
+ this.port = port;
+ }
+
+ public void connect() {
+ if (client == null) {
+ client = new MinaTaskClient(
+ "org.drools.process.workitem.wsht.WSHumanTaskHandler",
+ new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()));
+ NioSocketConnector connector = new NioSocketConnector();
+ SocketAddress address = new InetSocketAddress(ipAddress, port);
+ boolean connected = client.connect(connector, address);
+ if (!connected) {
+ throw new IllegalArgumentException(
+ "Could not connect task client");
+ }
+ }
+ }
+
+ public TaskRef getTaskById(long taskId) {
+ connect();
+ BlockingGetTaskResponseHandler responseHandler = new BlockingGetTaskResponseHandler();
+ client.getTask(taskId, responseHandler);
+ Task task = responseHandler.getTask();
+ return DroolsFlowTransform.task(task);
+ }
+
+ public void assignTask(long taskId, String idRef, String userId) {
+ connect();
+ BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
+ if (idRef == null) {
+ client.release(taskId, userId, responseHandler);
+ } else if (idRef.equals(userId)) {
+ client.claim(taskId, idRef, responseHandler);
+ } else {
+ client.delegate(taskId, userId, idRef, responseHandler);
+ }
+ responseHandler.waitTillDone(5000);
+ }
+
+ @SuppressWarnings("unchecked")
+ public void completeTask(long taskId, Map data, String userId) {
+ connect();
+ BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
+ client.start(taskId, userId, responseHandler);
+ responseHandler.waitTillDone(5000);
+ responseHandler = new BlockingTaskOperationResponseHandler();
+ ContentData contentData = null;
+ if (data != null) {
+ ByteArrayOutputStream bos = new ByteArrayOutputStream();
+ ObjectOutputStream out;
+ try {
+ out = new ObjectOutputStream(bos);
+ out.writeObject(data);
+ out.close();
+ contentData = new ContentData();
+ contentData.setContent(bos.toByteArray());
+ contentData.setAccessType(AccessType.Inline);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ client.complete(taskId, userId, contentData, responseHandler);
+ responseHandler.waitTillDone(5000);
+ }
+
+ @SuppressWarnings("unchecked")
+ public void completeTask(long taskId, String outcome, Map data, String userId) {
+ data.put("outcome", outcome);
+ completeTask(taskId, data, userId);
+ }
+
+ public void releaseTask(long taskId, String userId) {
+ // TODO: this method is not being invoked, it's using
+ // assignTask with null parameter instead
+ connect();
+ BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
+ client.release(taskId, userId, responseHandler);
+ responseHandler.waitTillDone(5000);
+ }
+
+ public List<TaskRef> getAssignedTasks(String idRef) {
+ connect();
+ List<TaskRef> result = new ArrayList<TaskRef>();
+ try {
+ BlockingTaskSummaryResponseHandler responseHandler = new BlockingTaskSummaryResponseHandler();
+ client.getTasksOwned(idRef, "en-UK", responseHandler);
+ List<TaskSummary> tasks = responseHandler.getResults();
+ for (TaskSummary task: tasks) {
+ if (task.getStatus() == Status.Reserved) {
+ result.add(DroolsFlowTransform.task(task));
+ }
+ }
+ } catch (Throwable t) {
+ t.printStackTrace();
+ }
+ return result;
+ }
+
+ public List<TaskRef> getUnassignedTasks(String idRef, String participationType) {
+ // TODO participationType ?
+ connect();
+ List<TaskRef> result = new ArrayList<TaskRef>();
+ try {
+ BlockingTaskSummaryResponseHandler responseHandler = new BlockingTaskSummaryResponseHandler();
+ client.getTasksAssignedAsPotentialOwner(idRef, "en-UK", responseHandler);
+ List<TaskSummary> tasks = responseHandler.getResults();
+ for (TaskSummary task: tasks) {
+ result.add(DroolsFlowTransform.task(task));
+ }
+ } catch (Throwable t) {
+ t.printStackTrace();
+ }
+ return result;
+ }
+
+}
Modified: labs/jbossrules/trunk/drools-process/drools-gwt-form/src/main/java/org/drools/integration/console/forms/ProcessFormDispatcher.java
===================================================================
--- labs/jbossrules/trunk/drools-process/drools-gwt-form/src/main/java/org/drools/integration/console/forms/ProcessFormDispatcher.java 2010-03-16 17:24:13 UTC (rev 32118)
+++ labs/jbossrules/trunk/drools-process/drools-gwt-form/src/main/java/org/drools/integration/console/forms/ProcessFormDispatcher.java 2010-03-16 18:03:01 UTC (rev 32119)
@@ -11,8 +11,7 @@
public class ProcessFormDispatcher extends AbstractFormDispatcher {
public URL getDispatchUrl(FormAuthorityRef ref) {
- System.out.println("getDispatchUrl " + ref.getReferenceId());
- InputStream template = getTemplate(ref.getReferenceId());
+ InputStream template = getTemplate(ref.getReferenceId());
if (template == null) {
return null;
}
@@ -20,8 +19,7 @@
}
public DataHandler provideForm(FormAuthorityRef ref) {
- System.out.println("provideForm " + ref.getReferenceId());
- InputStream template = getTemplate(ref.getReferenceId());
+ InputStream template = getTemplate(ref.getReferenceId());
if (template == null) {
return null;
}
Modified: labs/jbossrules/trunk/drools-process/drools-gwt-graph/src/main/resources/com.sample.evaluation.png
===================================================================
(Binary files differ)
More information about the jboss-svn-commits
mailing list