Examples of PIPATask

Examples of org.intalio.tempo.workflow.task.PIPATask

183
184
185
186
187
188
189
190
191
192
193
194
    // ------------------ Common deployment methods ------------------------

    public DeploymentMessage checkPipa(String token, InputStream input, String name) {
        DeploymentMessage msg = null;
        try {
            PIPATask task = loadPIPADescriptor(input);
            if (task.isValid()) {
                /*
                 * ALEX: Disabled until we get token propagation from
                 * deploy-impl PIPATask existing =
                 * wds.getPipaTask(task.getFormURLAsString(), token); if
                 * (existing != null) { msg = new DeploymentMessage(Level.ERROR,
View Full Code Here

Examples of org.intalio.tempo.workflow.task.PIPATask

208
209
210
211
212
213
214
215
216
217
218
219
220
    }

    public DeploymentMessage processPipa(String token, InputStream input, String name, ArrayList<String> urls) {
        DeploymentMessage msg = null;
        try {
            PIPATask task = loadPIPADescriptor(input);
            urls.add(getFormUrl(task));
            if (task.isValid()) {
                LOG.debug("Store PIPA {}", name);
                ITaskDAOConnection dao=_taskDAOFactory.openConnection();
                try {
                    _tms.deletePipa(dao,getFormUrl(task), token);
                } catch (Exception e) {
View Full Code Here

Examples of org.intalio.tempo.workflow.task.PIPATask

235
236
237
238
239
240
241
242
    }

    public PIPATask loadPIPADescriptor(InputStream input) throws IOException {
        Properties prop = new Properties();
        prop.load(input);
        PIPATask task = PIPALoader.parsePipa(prop);
        return task;
    }
View Full Code Here

Examples of org.intalio.tempo.workflow.task.PIPATask

341
342
343
344
345
346
347
348
349
350
351
352
353
354
            throws AuthException, UnavailableTaskException, AccessDeniedException, AxisFault {
        UserRoles credentials = _authProvider.authenticate(participantToken);
        Task task = dao.fetchTaskIfExists(taskID);
        checkIsAvailable(taskID, task, credentials);
        if (task instanceof PIPATask) {
            PIPATask pipaTask = (PIPATask) task;
            Document document = sendInitMessage(pipaTask, user, formUrl, participantToken, input);
            if (_logger.isDebugEnabled())
                _logger.debug(credentials.getUserID() + " has initialized process " + pipaTask.getProcessEndpoint()
                        + " with Workflow PIPA Task " + task);
            return document;
        } else {
            throw new UnavailableTaskException("Task (" + taskID
                    + ") is not a PIPA task cannot be used to initiate a process");
View Full Code Here

Examples of org.intalio.tempo.workflow.task.PIPATask

507
508
509
510
511
512
513
514
515
516
517
        _log.info(request.toString());

        try {
            OMElement response = sendRequest(request, TaskXMLConstants.TASK_NAMESPACE + "getPipaTask");
            OMElement taskElement = response.getFirstElement();
            PIPATask task = (PIPATask) new TaskUnmarshaller().unmarshalFullTask(taskElement);
            return task;
        } catch (InvalidInputFormatException e) {
            throw new RuntimeException(e);
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.