Examples of org.apache.ode.bpel.rtrep.v2.channels.PickResponseChannel

Package org.apache.ode.bpel.rtrep.v2.channels

Examples of org.apache.ode.bpel.rtrep.v2.channels.PickResponseChannel

org.apache.ode.bpel.rtrep.v2.channels.PickResponseChannel
Alarm event handler. This process template manages a single alarm event handler. It acts like an activity in that it can be terminated, but also adds a channel for "soft" termination (aka stopping) to deal with the case when the scope that owns the event handler completes naturally.

        }
        return msgType;
    }


    public OXsdTypeVarType resolveXsdType(QName typeName) throws CompilationException {
        OXsdTypeVarType type = _oprocess.xsdTypes.get(typeName);
        if (type == null) {
            SchemaModel model = null;
            try {
                model = _wsdlRegistry.getSchemaModel();
            } catch (IllegalArgumentException iaa) { }
            if (model == null || !model.knowsSchemaType(typeName))
                throw new CompilationException(__cmsgs.errUndeclaredXsdType(typeName));


            type = new OXsdTypeVarType(_oprocess);
            type.debugInfo = createDebugInfo(_processDef, "XSD Type: " + typeName);
            type.xsdType = typeName;
            type.simple = _wsdlRegistry.getSchemaModel().isSimpleType(typeName);
            _oprocess.xsdTypes.put(typeName, type);
        }

View Full Code Here

                throw new CompilationException(__msgs
                    .errInvalidNumberOfArguments(Constants.EXT_FUNCTION_DOXSLTRANSFORM));
            }


            String xslUri = (String) params.get(0);
            OXslSheet xslSheet = _cctx.compileXslt(xslUri);
            try {
                XslTransformHandler.getInstance().parseXSLSheet(_cctx.getBaseResourceURI(), xslSheet.uri,
                    xslSheet.sheetBody, new XslCompileUriResolver(_cctx, _out));
            } catch (Exception e) {
                throw new CompilationException(__msgs.errXslCompilation(xslUri, e.toString()));

View Full Code Here

            uri = new URI(FileUtils.encodePath(href));
        } catch (URISyntaxException e) {
            return null;
        }


        OXslSheet sheet = _expr.xslSheets.get(uri);
        if( sheet != null) {
            result = sheet.sheetBody;
        } else {
            result = getResourceAsString(uri);
        }

View Full Code Here

          uri = new URI(FileUtils.encodePath(href));
      } catch (URISyntaxException e) {
          return null;
      }


      OXslSheet sheet = _expr.xslSheets.get(uri);
      if( sheet != null) {
          result = sheet.sheetBody;
      } else {
          result = getResourceAsString(uri);
      }

View Full Code Here

                throw new CompilationException(
                        __msgs.errInvalidNumberOfArguments(Constants.EXT_FUNCTION_DOXSLTRANSFORM));
            }


            String xslUri = (String) params.get(0);
            OXslSheet xslSheet = _cctx.compileXslt(xslUri);
            try {
                XslTransformHandler.getInstance().parseXSLSheet(_cctx.getBaseResourceURI(), xslSheet.uri, xslSheet.sheetBody,
                        new XslCompileUriResolver(_cctx, _out));
            } catch (Exception e) {
                throw new CompilationException(__msgs.errXslCompilation(xslUri, e.toString()));

View Full Code Here

        String sheetBody = loadXsltSheet(_processURI.resolve(docUri));
        if (sheetBody == null) {
            throw new CompilationException(__cmsgs.errCantFindXslt(docStrUri));
        }


        OXslSheet oXslSheet = new OXslSheet(_oprocess);
        oXslSheet.uri = docUri;
        oXslSheet.sheetBody = sheetBody;


        _oprocess.xslSheets.put(oXslSheet.uri, oXslSheet);
        return oXslSheet;

View Full Code Here

    _cc = cc;
    _expr = expr;
  }


  public Source resolve(String href, String base) throws TransformerException {
    OXslSheet xslSheet = _cc.compileXslt(href);
    _expr.xslSheets.put(xslSheet.uri, xslSheet);
    return new StreamSource(new StringReader(xslSheet.sheetBody));
  }

View Full Code Here

                }


                public void completed(FaultData faultData, Set<CompensationHandler> compensations) {
                  if (faultData != null) {
                        if (!isScopeRetryable()) {
                          FaultData fault = createFault(getConstants().qnScopeRollback, faultData.getFaultMessage(), null, SCOPEACT.this._self.o);
                            _parent.completed(fault, CompensationHandler.emptySet());
                            _linkStatusInterceptor.val(false);
                            unlockAll(false);
                        } else {
                          unlockAll(true);
                        }
                  } else {
                        _parent.completed(faultData, compensations);
                        _linkStatusInterceptor.val(faultData == null);
                        unlockAll(false);
                        // no more listening
                  }
                  getBpelRuntime().setRetriedOnce();
                }


                public void failure(String reason, Element data) {
                  unlockAll(true);
                    if (!isScopeRetryable()) {
                      FaultData fault = createFault(getConstants().qnScopeRollback, data, null, SCOPEACT.this._self.o);
                        _parent.completed(fault, CompensationHandler.emptySet());
                        _linkStatusInterceptor.val(false);
                    }
                }

View Full Code Here


    /**
     * @see org.apache.ode.jacob.JacobRunnable#run()
     */
    public void run() {
        PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
        Date timeout;
        Selector[] selectors;


        try {
            selectors = new Selector[_opick.onMessages.size()];

View Full Code Here

         * @see org.apache.ode.jacob.JacobRunnable#run()
         */
        public void run() {
            Selector selector;
            try {
                PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
                CorrelationKey key;
                PartnerLinkInstance pLinkInstance = _scopeFrame.resolve(_oevent.partnerLink);
                if (_oevent.matchCorrelation == null) {
                    // Adding a route for opaque correlation. In this case correlation is done on "out-of-band" session id.
                    String sessionId = getBpelRuntime().fetchMySessionId(pLinkInstance);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.ode.bpel.rtrep.v2.channels.PickResponseChannel

net.sf.saxon.value.QNameValue

org.apache.ode.bpel.common.CorrelationKey

org.apache.ode.bpel.compiler.v2.AssignGenerator

org.apache.ode.bpel.compiler.v2.BpelCompilerImpl

org.apache.ode.bpel.compiler.v2.ExtensionActivtityGenerator

org.apache.ode.bpel.compiler.v2.FlowGenerator

org.apache.ode.bpel.compiler.v2.ForEachGenerator

org.apache.ode.bpel.compiler.v2.IfGenerator

org.apache.ode.bpel.compiler.v2.InvokeGenerator

org.apache.ode.bpel.compiler.v2.PickGenerator

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.