Package org.jbpm.task.service

Examples of org.jbpm.task.service.ContentData


        String procedureId = (String) value.get("procedureId");

        Map<String, Object> info = new HashMap<String, Object>();
        info.put("emergency.vehicles", selectedVehicles);
        ContentData result = new ContentData();
        result.setAccessType(AccessType.Inline);
        result.setType("java.util.Map");
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ObjectOutputStream out = new ObjectOutputStream(bos);
        out.writeObject(info);
        out.close();
        result.setContent(bos.toByteArray());

        BlockingTaskOperationResponseHandler completeTaskOperationHandler = new BlockingTaskOperationResponseHandler();
        client.complete(garageTask.getId(), "garage_emergency_service", result, completeTaskOperationHandler);

        Thread.sleep(3000);
View Full Code Here


        Assert.assertNotNull(value);

        Map<String, Object> info = new HashMap<String, Object>();
        info.put("emergency.priority", 1);
        ContentData result = new ContentData();
        result.setAccessType(AccessType.Inline);
        result.setType("java.util.Map");
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ObjectOutputStream out = new ObjectOutputStream(bos);
        out.writeObject(info);
        out.close();
        result.setContent(bos.toByteArray());

        BlockingTaskOperationResponseHandler completeTaskOperationHandler = new BlockingTaskOperationResponseHandler();
        client.complete(task.getId(), user, result, completeTaskOperationHandler);

        Thread.sleep(2000);
View Full Code Here

        String procedureId = (String) value.get("procedureId");

        Map<String, Object> info = new HashMap<String, Object>();
        info.put("emergency.vehicles", selectedVehicles);
        ContentData result = new ContentData();
        result.setAccessType(AccessType.Inline);
        result.setType("java.util.Map");
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ObjectOutputStream out = new ObjectOutputStream(bos);
        out.writeObject(info);
        out.close();
        result.setContent(bos.toByteArray());

        BlockingTaskOperationResponseHandler completeTaskOperationHandler = new BlockingTaskOperationResponseHandler();
        client.complete(garageTask.getId(), "garage_emergency_service", result, completeTaskOperationHandler);

        Thread.sleep(3000);
View Full Code Here

        Assert.assertNotNull(value);

        Map<String, Object> info = new HashMap<String, Object>();
        info.put("emergency.priority", 1);
        ContentData result = new ContentData();
        result.setAccessType(AccessType.Inline);
        result.setType("java.util.Map");
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ObjectOutputStream out = new ObjectOutputStream(bos);
        out.writeObject(info);
        out.close();
        result.setContent(bos.toByteArray());

        BlockingTaskOperationResponseHandler completeTaskOperationHandler = new BlockingTaskOperationResponseHandler();
        client.complete(task.getId(), user, result, completeTaskOperationHandler);
       
        Thread.sleep(2000);
View Full Code Here

        Map<String, Object> info = new HashMap<String, Object>();
        info.put("emergency", emergency);


        ContentData result = new ContentData();
        result.setAccessType(AccessType.Inline);
        result.setType("java.util.Map");
        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ObjectOutputStream out = new ObjectOutputStream(bos);
        out.writeObject(info);
        out.close();
        result.setContent(bos.toByteArray());

        BlockingTaskOperationResponseHandler completeTaskOperationHandler = new BlockingTaskOperationResponseHandler();
        client.complete(sums.get(0).getId(), "operator", result, completeTaskOperationHandler);

View Full Code Here

  }

  public void completeTask(User user, TaskSummary task, Map data) {
    System.out.println("Completing task " + task.getId());
    BlockingTaskOperationResponseHandler operationResponseHandler = 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) {
        System.err.print(e);
      }
    }
View Full Code Here

    Map<String, Object> taskParams = new HashMap<String, Object>();
    taskParams.put("Explanation", "Great work");
    taskParams.put("Outcome", "Approved");
   
    // Serialized and inserted.
    ContentData content = new ContentData();
    content.setAccessType(AccessType.Inline);
    content.setContent(getByteArrayFromObject(taskParams));
   
    // add results of task.
    taskService.complete(task.getId(), "mary", content);
   
View Full Code Here

    Map<String, Object> taskParams = new HashMap<String, Object>();
    taskParams.put("Explanation", "Too complicated for me");
    taskParams.put("Outcome", "Rejected");
   
    // Serialized and inserted.
    ContentData content = new ContentData();
    content.setAccessType(AccessType.Inline);
    content.setContent(getByteArrayFromObject(taskParams));
   
    // add results of task.
    taskService.complete(task.getId(), "john", content);
   
View Full Code Here

       Map<String, Object> taskParams = new HashMap<String, Object>();
    taskParams.put("Explanation", "Great work");
    taskParams.put("Outcome", "Approved");
   
    // Serialized and inserted.
    ContentData content = new ContentData();
    content.setAccessType(AccessType.Inline);
    content.setContent(getByteArrayFromObject(taskParams));
   
    client.complete(tasks.get(0).getId(), "mary", content, responseHandler);
    responseHandler.waitTillDone(1000);
      
   
View Full Code Here

    Map<String, Object> taskParams = new HashMap<String, Object>();
    taskParams.put("Explanation", "Great work");
    taskParams.put("Outcome", "Approved");
   
    // Serialized and inserted.
    ContentData content = new ContentData();
    content.setAccessType(AccessType.Inline);
    content.setContent(getByteArrayFromObject(taskParams));
   
    // add results of task.
    taskService.complete(task.getId(), "mary", content);
    assertProcessInstanceCompleted(processInstance.getId(), ksession);
    assertNodeTriggered(processInstance.getId(), "End Approved");
View Full Code Here

TOP

Related Classes of org.jbpm.task.service.ContentData

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.