Package org.jboss.soa.esb.services.jbpm

Examples of org.jboss.soa.esb.services.jbpm.JBpmObjectMapper


        processInstance.getContextInstance().createVariable("g2", helloWorldGlobalScope);
        processInstance.getContextInstance().createVariable("h3", objectTokenScope, token);
        processInstance.getContextInstance().createVariable("i4", objectGlobalScope);
        ExecutionContext executionContext = new ExecutionContext(token);
       
        JBpmObjectMapper mapper = new JBpmObjectMapper();
        Message message = mapper.mapFromJBpmToEsbMessage(bpmToEsbVars, Boolean.FALSE, executionContext);
       
        //Setting up return mapping for the callback service.
        EsbActionHandler esbActionHandler = new EsbActionHandler();
        EPR epr = esbActionHandler.createReplyTo(esbToBpmVars.asXML(), Boolean.FALSE, executionContext);
        String esbToBpmXml = epr.getAddr().getExtensionValue(Constants.ESB_TO_BPM_VARS_TAG);
       
        //Obtaining the VariableMap that is going to be set callback command
        Map<String,Object> variableMap = mapper.mapFromEsbMessageToJBpmMap(message, esbToBpmVars.asXML());
        logger.info(variableMap);
        //Let's make sure that what we put in is going to make it roundtrip.
        assertEquals(helloWorldTokenScope, variableMap.get("x1"));
        assertEquals(helloWorldGlobalScope,variableMap.get("x2"));
    }
View Full Code Here


                    final DefaultElement esbToBpmVars = handler.esbToBpmVars;
                    if (esbToBpmVars != null)
                    {
                        try
                        {
                            return  new JBpmObjectMapper().mapFromEsbMessageToJBpmMapping(esbMessage, esbToBpmVars.asXML());
                        }
                        catch (final ConfigurationException e)
                        {
                            throw new CallbackException(e.getMessage(), e);
                        }
View Full Code Here

        if (millisToWaitForResponse !=null) {
            logger.info("millisToWaitForResponse is no longer a valid element, please use a " +
                    "jBPM timer for this node instead.");
        }
        //Create the ESB Message
        JBpmObjectMapper mapper = new JBpmObjectMapper();
      Message message = mapper.mapFromJBpmToEsbMessage(bpmToEsbVars, globalProcessScope, executionContext);
        //Set the replyTo to the JBpmCallback Service
        String esbToBpmVarsXml=null;
        if (esbToBpmVars!=null) {
            esbToBpmVarsXml = esbToBpmVars.asXML();
        }
View Full Code Here

            if (null == esbServiceName) {
                throw new ConfigurationException(
                    "Service name (esbServiceName element) must not be null");
            }
        }
        JBpmObjectMapper mapper = new JBpmObjectMapper();
        Message message = mapper.mapFromJBpmToEsbMessage(bpmToEsbVars, globalProcessScope, executionContext);
       
        final ContextInstance contextInstance = executionContext.getContextInstance();
       
        if (isReplyToOrFaultToSet(contextInstance))
        {
View Full Code Here

TOP

Related Classes of org.jboss.soa.esb.services.jbpm.JBpmObjectMapper

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.