Examples of org.apache.ode.bpel.iapi.MyRoleMessageExchange.invoke()

Class org.apache.ode.bpel.iapi.MyRoleMessageExchange

Examples of org.apache.ode.bpel.iapi.MyRoleMessageExchange.invoke()

org.apache.ode.bpel.iapi.MyRoleMessageExchange.invoke()
"Invoke" a process hosted by the BPEL engine. The state of the invocation may be obtained by a call to the {@link MessageExchange#getStatus()}method. It is possible that the response for the operation is not immediately available (i.e the call to {@link #invoke(Message)} willreturn before a response is available). In such cases, {@link MessageExchange#getStatus()} == {@link Status#ASYNC} and theintegration layer will receive an asynchronous notification from the BPEL engine via the {@link MessageExchangeContext#onAsyncReply(MyRoleMessageExchange)} whenthe response become available.

                mexContext.clearCurrentResponse();


                Message request = mex.createMessage(_invocation.requestType);
                request.setMessage(_invocation.request);
                _invocation.invokeTime = System.currentTimeMillis();
                running = mex.invoke(request);


                Status status = mex.getStatus();
                CorrelationStatus cstatus = mex.getCorrelationStatus();
                if (_invocation.expectedStatus != null && !status.equals(_invocation.expectedStatus))
                    failure(_invocation, "Unexpected message exchange status", _invocation.expectedStatus, status);

View Full Code Here


            Document doc = camelContext.getTypeConverter().convertTo(Document.class, "<message><TestPart>" + name + "</TestPart></message>");
            msg.setMessage(doc.getDocumentElement());


            LOG.info("Sending msg " + msg);
            running = role.invoke(msg);
        } finally {
            scheduler.commitTransaction();
        }


        running.get(10000, TimeUnit.MILLISECONDS);

View Full Code Here

                mex = odeServer.getBpelServer().getEngine().createMessageExchange(new GUID().toString(),
                        new QName("http://tuscany.apache.org/implementation/bpel/example/helloworld.wsdl", "HelloService"), "hello");


                Message request = mex.createMessage(new QName("", ""));
                request.setMessage(DOMUtils.stringToDOM("<message><TestPart><hello xmlns=\"http://tuscany.apache.org/implementation/bpel/example/helloworld.wsdl\">Hello</hello></TestPart></message>"));
                onhold = mex.invoke(request);
                txMgr.commit();
            } catch (Exception e) {
                e.printStackTrace();
                txMgr.rollback();
            }

View Full Code Here

                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_MYROLE_SESSIONID, partnerSessionId);
            if ( mySessionId != null )
                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_PARTNERROLE_SESSIONID, mySessionId);


            mex.setStatus(MessageExchange.Status.REQUEST);
            myRoleMex.invoke(odeRequest);


            // Can't expect any sync response
            scheduleInvokeCheck(mex, partnerLink.partnerLink, true);
            mex.replyAsync();
        } else {

View Full Code Here

                    throw new MessageTranslationException(errmsg);


                }
                odeMex.setProperty(Mapper.class.getName(), mapper.getClass().getName());
                mapper.toODE(odeRequest, request, msgdef);
                odeMex.invoke(odeRequest);


                // Handle the response if it is immediately available.
                if (odeMex.getStatus() != Status.ASYNC) {
                    if (__log.isDebugEnabled()) {
                        __log.debug("ODE MEX " + odeMex + " completed SYNCHRONOUSLY.");

View Full Code Here

                    __log.debug("Invoking ODE using MEX " + odeMex);
                    __log.debug("Message content:  " + DOMUtils.domToString(odeRequest.getMessage()));
                }


                // Invoke ODE
                responseFuture = odeMex.invoke(odeRequest);


                __log.debug("Commiting ODE MEX " + odeMex);
                try {
                    if (__log.isDebugEnabled()) __log.debug("Commiting transaction.");
                    _txManager.commit();

View Full Code Here

            Element wrapper = body.getOwnerDocument().createElementNS("", "main");
            wrapper.appendChild(body);
            Element message = body.getOwnerDocument().createElementNS("", "message");
            message.appendChild(wrapper);
            request.setMessage(message);
            mex.invoke(request);
            mex.complete();
            _txManager.commit();
        } catch (Exception except) {
              _txManager.rollback();
              throw except;

View Full Code Here

                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_MYROLE_SESSIONID, partnerSessionId);
            if ( mySessionId != null )
                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_PARTNERROLE_SESSIONID, mySessionId);


            mex.setStatus(MessageExchange.Status.REQUEST);
            myRoleMex.invoke(odeRequest);


            // Can't expect any sync response
            mex.replyAsync();
        } else {
            // If we couldn't find the endpoint, then there is no sense

View Full Code Here

                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_MYROLE_SESSIONID, partnerSessionId);
            if ( mySessionId != null )
                myRoleMex.setProperty(MessageExchange.PROPERTY_SEP_PARTNERROLE_SESSIONID, mySessionId);


            mex.setStatus(MessageExchange.Status.REQUEST);
            myRoleMex.invoke(odeRequest);


            // Can't expect any sync response
            scheduleInvokeCheck(mex, partnerLink.partnerLink, true);
            mex.replyAsync();
        } else {

View Full Code Here

                    __log.debug("Invoking ODE using MEX " + odeMex);
                    __log.debug("Message content:  " + DOMUtils.domToString(odeRequest.getMessage()));
                }


                // Invoke ODE
                responseFuture = odeMex.invoke(odeRequest);


                __log.debug("Commiting ODE MEX " + odeMex);
                try {
                    if (__log.isDebugEnabled()) __log.debug("Commiting transaction.");
                    _txManager.commit();

View Full Code Here

0 1 2 3 4

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.