Examples of ProcessManagementException

org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

        try {
            tenantProcessStore.setState(pid, ProcessState.RETIRED);
        } catch (Exception e) {
            String errMsg = "Process: " + pid + " retirement failed.";
            log.error(errMsg, e);
            throw new ProcessManagementException(errMsg);
        }
    }

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

        try {
            tenantProcessStore.setState(pid, ProcessState.ACTIVE);
        } catch (Exception e) {
            String errMsg = "Process: " + pid + " activation failed.";
            log.error(errMsg, e);
            throw new ProcessManagementException(errMsg);
        }
    }

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

            return serviceEPRs.toArray(new String[serviceEPRs.size()]);
        }


        String errMsg = "Cannot find service for process: " + processId;
        log.error(errMsg);
        throw new ProcessManagementException(errMsg);
    }

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

                if (service == null) {
                    String errorMsg = "Error in <provide> element for process " +
                            processInfo.getName() + " partnerlink" + plinkName +
                            " did not identify an endpoint";
                    log.error(errorMsg);
                    throw new ProcessManagementException(errorMsg);
                }
                if (log.isDebugEnabled()) {
                    log.debug("Processing <provide> element for process " + processInfo.getName() +
                            ": partnerlink " + plinkName + " --> " + service.getName() + " : " +
                            service.getPort());
                }


                QName serviceName = service.getName();
                EndpointRef_type0 eprType = new EndpointRef_type0();
                eprType.setPartnerLink(plinkName);
                eprType.setService(serviceName);
                ServiceLocation sLocation = new ServiceLocation();
                try {
                    String url = Utils.getTryitURL(serviceName.getLocalPart(), getConfigContext());
                    sLocation.addServiceLocation(url);
                } catch (AxisFault axisFault) {
                    String errMsg = "Error while getting try-it url for the service: " + serviceName;
                    log.error(errMsg, axisFault);
                    throw new ProcessManagementException(errMsg, axisFault);
                }
                eprType.setServiceLocations(sLocation);
                eprsType.addEndpointRef(eprType);
            }
            pInfo.setEndpoints(eprsType);

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

                        dd = ISO8601DateParser.parse(Filter.getDateWithoutOp(ddf));
                    } catch (ParseException e) {
                        // Should never happen.
                        String errMsg = "Exception while parsing date";
                        log.error(errMsg, e);
                        throw new ProcessManagementException(errMsg, e);
                    }


                    CollectionsX.remove_if(confs, new MemberOfFunction<ProcessConf>() {
                        @Override
                        public boolean isMember(ProcessConf o) {

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

                                 TenantProcessStoreImpl tenantProcessStore)
            throws ProcessManagementException {
        if (pconf == null) {
            String errMsg = "Process configuration cannot be null.";
            log.error(errMsg);
            throw new ProcessManagementException(errMsg);
        }


        info.setPid(pconf.getProcessId().toString());
        // TODO: ACTIVE and RETIRED should be used separately.
        // Active process may be retired at the same time

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException

        try {
            return bpelDb.exec(callable);
        } catch (Exception ex) {
            String errMsg = "Exception during database operation ";
            log.error(errMsg, ex);
            throw new ProcessManagementException(errMsg, ex);
        }
    }

View Full Code Here

Examples of org.wso2.carbon.bpel.skeleton.ode.integration.mgt.services.ProcessManagementException


    private OMElement getProcessDefinition(ProcessConf pConf) throws ProcessManagementException {
        if (pConf == null) {
            String errMsg = "Process configuration cannot be null.";
            log.error(errMsg);
            throw new ProcessManagementException(errMsg);
        }


        String bpelDoc = pConf.getBpelDocument();
        List<File> files = pConf.getFiles();


        for (final File file : files) {
            if (file.getPath().endsWith(bpelDoc) ||
                    file.getPath().endsWith(bpelDoc.replaceAll("/", "\\\\"))) {
                XMLStreamReader reader;
                FileInputStream fis = null;
                OMElement bpelDefinition;
                try {
                    fis = new FileInputStream(file);
                    XMLInputFactory xif = XMLInputFactory.newInstance();
                    reader = xif.createXMLStreamReader(fis);
                    StAXOMBuilder builder = new StAXOMBuilder(reader);
                    bpelDefinition = builder.getDocumentElement();
                    bpelDefinition.build();
                } catch (XMLStreamException e) {
                    String errMsg = "XML stream reader exception: " + file.getAbsolutePath();
                    log.error(errMsg, e);
                    throw new ProcessManagementException(errMsg, e);
                } catch (FileNotFoundException e) {
                    String errMsg = "BPEL File reading exception: " + file.getAbsolutePath();
                    log.error(errMsg, e);
                    throw new ProcessManagementException(errMsg, e);
                } finally {
                    if (fis != null) {
                        try {
                            fis.close();
                        } catch (IOException e) {
                            log.warn("Cannot close file input stream.", e);
                        }
                    }
                }


                return bpelDefinition;
            }
        }


        String errMsg = "Process Definition for: " + pConf.getProcessId() + " not found";
        log.error(errMsg);
        throw new ProcessManagementException(errMsg);
    }

View Full Code Here

TOP

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.