Package org.wso2.carbon.rulecep.commons.descriptions

Examples of org.wso2.carbon.rulecep.commons.descriptions.QNameFactory


    }

    public byte[] getProcessImage(String processId) {

        QName qName = decode(processId);
        SVGInterface svg = createSVG(qName);
        return svg.toPNGBytes();
    }
View Full Code Here


    private SVGInterface createSVG(QName qName) {

        // generate new
        InputStream in = getBpelDescriptor(qName);

        SVGInterface svg = null;

        try {
            svg = BPEL2SVGUtil.generate(in);

            if (svg == null)
View Full Code Here

   
    protected static SVGImpl generateSVGImpl(java.io.InputStream is) throws java.io.IOException {
      byte[] b=new byte[is.available()];
      is.read(b);
   
      BPELInterface bpel = new BPELImpl();
        OMElement bpelStr = bpel.load(new String(b));
       
        bpel.processBpelString(bpelStr);

        LayoutManager layoutManager = BPEL2SVGFactory.getInstance().getLayoutManager();
        layoutManager.setVerticalLayout(true);
        layoutManager.setYSpacing(20);
        layoutManager.setYSpacing(50);
        layoutManager.layoutSVG(bpel.getRootActivity());

        SVGImpl svg = new SVGImpl();
        svg.setRootActivity(bpel.getRootActivity());
       
        return(svg);
    }
View Full Code Here

   * @param transformer The optional image transformer
   * @throws java.io.IOException Failed to generate the representation
   */
    public static void generate(java.io.InputStream is, java.io.OutputStream os,
                SVGImageTransformer transformer) throws java.io.IOException {
        SVGImpl svg = generateSVGImpl(is);
       
        if (transformer == null) {
          String str=svg.getHeaders()+svg.generateSVGString();
          os.write(str.getBytes());
        } else {
          transformer.transform(svg, os);
        }
    }
View Full Code Here

        layoutManager.setVerticalLayout(true);
        layoutManager.setYSpacing(20);
        layoutManager.setYSpacing(50);
        layoutManager.layoutSVG(bpel.getRootActivity());

        SVGImpl svg = new SVGImpl();
        svg.setRootActivity(bpel.getRootActivity());
       
        return(svg);
    }
View Full Code Here

        if (ServiceDescription.TYPE.equals(extensibleConfiguration.geType())) {

            ServiceDescription serviceDescription = (ServiceDescription) extensibleConfiguration;
            QName parentQName = element.getQName();
            QNameFactory qNameFactory = QNameFactory.getInstance();

            // rule set
            QName parameterQName = qNameFactory.createQName(CommonsConstants.ELE_QUERY,
                    parentQName);
            OMElement parameterElem = element.getFirstChildWithName(parameterQName);
            if (parameterElem == null) {
                return;
            }
            QueryDescription description =
                    QueryDescriptionFactory.create(parameterElem, xPathFactory);
            serviceDescription.setServiceExtensionDescription(description);
            if (serviceDescription.getExtension() == null) {
                serviceDescription.setExtension(FILE_EXTENSION);
            }
            if (serviceDescription.getTargetNamespace() == null) {
                serviceDescription.setTargetNamespace(TARGET_NAMESPACE);
            }
            if (serviceDescription.getTargetNSPrefix() == null) {
                serviceDescription.setTargetNSPrefix(TARGET_NAMESPACE_PREFIX);
            }
        } else if (OperationDescription.TYPE.equals(extensibleConfiguration.geType())) {

            OperationDescription operationDescription =
                    (OperationDescription) extensibleConfiguration;
            operationDescription.setForceInOnly(true);
            CEPOperationExtensionDescription extensionDescription =
                    new CEPOperationExtensionDescription();

            QName parentQName = element.getQName();
            QNameFactory qNameFactory = QNameFactory.getInstance();

            QName inStreamQName = qNameFactory.createQName(CommonsConstants.ELE_INPUT_EVENT_STREAM,
                    parentQName);
            OMElement inStreamElement = element.getFirstChildWithName(inStreamQName);
            if (inStreamElement != null) {
                EventStreamDescription streamDescription =
                        EventStreamDescriptionFactory.create(inStreamElement, xPathFactory);
                extensionDescription.setInputEventStream(streamDescription);
            }

            QName outStreamQName = qNameFactory.createQName(CommonsConstants.ELE_OUTPUT_EVENT_STREAM,
                    parentQName);
            OMElement outStreamElement = element.getFirstChildWithName(outStreamQName);
            if (outStreamElement != null) {
                EventStreamDescription streamDescription =
                        EventStreamDescriptionFactory.create(outStreamElement, xPathFactory);
View Full Code Here

                                                         XPathFactory xPathFactory,
                                                         ExtensionBuilder extensionBuilder) {

        final RuleServiceExtensionDescription description = new RuleServiceExtensionDescription();
        QName parentQName = configuration.getQName();
        QNameFactory qNameFactory = QNameFactory.getInstance();

        // rule set
        QName parameterQName = qNameFactory.createQName(CommonsConstants.ELE_RULESET,
                parentQName);
        OMElement parameterElem = configuration.getFirstChildWithName(parameterQName);
        if (parameterElem != null) {
            RuleSetDescription ruleSetDescription =
                    RuleSetDescriptionFactory.create(parameterElem, xPathFactory, extensionBuilder);
View Full Code Here

        serviceDescription.setContainsServicesXML(
                Boolean.parseBoolean(
                        configuration.getAttributeValue(CommonsConstants.ATT_GENERATE_SERVICES_XML)));

        QName parentQName = configuration.getQName();
        QNameFactory qNameFactory = QNameFactory.getInstance();

        // description
        QName descriptionQName = qNameFactory.createQName(CommonsConstants.ELE_DESCRIPTION,
                parentQName);
        OMElement descriptionElement = configuration.getFirstChildWithName(descriptionQName);
        if (descriptionElement != null) {
            String description = descriptionElement.getText();
            if (description != null) {
View Full Code Here

     */
    public static RuleMediatorDescription create(OMElement configurationXML,
                                                 XPathFactory xPathFactory,
                                                 ExtensionBuilder configurationExtensionBuilder) {
        QName tagQName = configurationXML.getQName();
        QNameFactory qNameFactory = QNameFactory.getInstance();
        RuleMediatorDescription ruleMediatorDescription = new RuleMediatorDescription();
        QName sessionQName = qNameFactory.createQName(CommonsConstants.ELE_SESSION, tagQName);
        OMElement sessionElement = configurationXML.getFirstChildWithName(sessionQName);

        if (sessionElement != null) {
            SessionDescription description =
                    SessionDescriptionFactory.create(sessionElement, xPathFactory);
            ruleMediatorDescription.setSessionDescription(description);
        }

        QName executionSetQName = qNameFactory.createQName(CommonsConstants.ELE_RULESET,
                tagQName);
        OMElement executionSetElement = configurationXML.getFirstChildWithName(executionSetQName);

        if (executionSetElement != null) {
            RuleSetDescription description =
                    RuleSetDescriptionFactory.create(executionSetElement, xPathFactory,
                            configurationExtensionBuilder);
            ruleMediatorDescription.setRuleSetDescription(description);
        } else {
            throw new LoggedRuntimeException("ruleset configuration element must be given",
                    log);
        }

        QName factsQName = qNameFactory.createQName("facts", tagQName);
        OMElement factsElement = configurationXML.getFirstChildWithName(factsQName);
        if (factsElement != null) {
            QName inputQName = qNameFactory.createQName(CommonsConstants.ELE_FACT,
                    tagQName);
            Iterator inputs = factsElement.getChildrenWithName(inputQName);
            while (inputs.hasNext()) {
                OMElement inputElem = (OMElement) inputs.next();
                ResourceDescription input =
                        ResourceDescriptionFactory.createResourceDescription(inputElem,
                                xPathFactory);
                if (input != null) {
                    ruleMediatorDescription.addFactDescription(input);
                }
            }
        }

        QName resultsQName = qNameFactory.createQName("results", tagQName);
        OMElement resultsElement = configurationXML.getFirstChildWithName(resultsQName);
        if (resultsElement != null) {
            QName outputQName = qNameFactory.createQName(CommonsConstants.ELE_RESULT,
                    tagQName);
            Iterator outputs = resultsElement.getChildrenWithName(outputQName);
            while (outputs.hasNext()) {
                OMElement outputElem = (OMElement) outputs.next();
                ResourceDescription output =
View Full Code Here

                    "expect RuleSetDescription.", log);
        }

        RuleSetDescription description = (RuleSetDescription) extensibleConfiguration;
        QName parentQName = ruleSet.getQName();
        QNameFactory qNameFactory = QNameFactory.getInstance();
        QName sourceQName = qNameFactory.createQName(CommonsConstants.ELE_SOURCE,
                parentQName);

        OMElement sourceElement = ruleSet.getFirstChildWithName(sourceQName);
        if (sourceElement == null) {
            throw new LoggedRuntimeException("Invalid configuration. " +
View Full Code Here

TOP

Related Classes of org.wso2.carbon.rulecep.commons.descriptions.QNameFactory

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.