sendmuleevent.java

提供ESB 应用mule源代码 提供ESB 应用mule源代码

/*
 * $Id: SendMuleEvent.java 11967 2008-06-05 20:32:19Z dfeist $
 * --------------------------------------------------------------------------------------
 * Copyright (c) MuleSource, Inc.  All rights reserved.  http://www.mulesource.com
 *
 * The software in this package is published under the terms of the CPAL v1.0
 * license, a copy of which has been included with this distribution in the
 * LICENSE.txt file.
 */

package org.mule.transport.bpm.jbpm.actions;

import org.mule.api.MuleMessage;
import org.mule.api.config.MuleProperties;
import org.mule.transport.bpm.ProcessConnector;
import org.mule.transport.bpm.jbpm.MuleMessageService;
import org.mule.util.StringUtils;

import java.util.HashMap;
import java.util.Map;

import org.apache.commons.jxpath.JXPathContext;
import org.jbpm.graph.exe.ExecutionContext;

/**
 * Sends a Mule message to the specified endpoint. If the message is synchronous, 
 * the response from Mule will be automatically stored in PROCESS_VARIABLE_INCOMING.
 * 
 * @param endpoint - the Mule endpoint
 * @param transformers - any transformers to be applied
 * @param payload - specify the payload as a string directly in the jPDL
 * @param payloadSource - process variable from which to generate the message
 *            payload, defaults to {@link ProcessConnector.PROCESS_VARIABLE_DATA} or
 *            {@link ProcessConnector.PROCESS_VARIABLE_INCOMING}
 * @param messageProperties - any properties to be applied to the message
 */
public class SendMuleEvent extends LoggingActionHandler
{

    private static final long serialVersionUID = 1L;

    boolean synchronous = true;
    String endpoint = null;
    String transformers = null;
    Map properties = null;
    
    // Use "payload" to easily specify the payload as a string directly in the jPDL.
    // Use "payloadSource" to get the payload from a process variable. 
    String payload = null;
    String payloadSource = null;
    
    // The actual payload (as an object) will be stored here.
    private Object payloadObject;

    public void execute(ExecutionContext executionContext) throws Exception
    {
        super.execute(executionContext);

        MuleMessageService mule = (MuleMessageService) executionContext.getJbpmContext().getServices()
            .getMessageService();

        if (transformers != null)
        {
            endpoint += "?transformers=" + transformers;
        }

        if (payload == null)
        {
            if (payloadSource == null)
            {
                payloadObject = executionContext.getVariable(ProcessConnector.PROCESS_VARIABLE_DATA);
                if (payloadObject == null)
                {
                    payloadObject = executionContext.getVariable(ProcessConnector.PROCESS_VARIABLE_INCOMING);
                }
            }
            else
            {
                // The payloadSource may be specified using JavaBean notation (e.g.,
                // "myObject.myStuff.myField" would first retrieve the process
                // variable "myObject" and then call .getMyStuff().getMyField()
                String[] tokens = StringUtils.split(payloadSource, ".", 2);
                payloadObject = executionContext.getVariable(tokens[0]);
                if (tokens.length > 1)
                {
                    JXPathContext context = JXPathContext.newContext(payloadObject);
                    payloadObject = context.getValue(tokens[1].replaceAll("\\.", "/"));
                }
            }
        }
        else
        {
            payloadObject = payload;
        }
        if (payloadObject == null)
        {
            throw new IllegalArgumentException("Payload for message is null.  Payload source is \""
                            + payloadSource + "\"");
        }

        Map props = new HashMap();
        props.put(ProcessConnector.PROPERTY_PROCESS_TYPE, executionContext.getProcessDefinition().getName());
        props.put(ProcessConnector.PROPERTY_PROCESS_ID, new Long(executionContext.getProcessInstance()
            .getId()));
        props.put(MuleProperties.MULE_CORRELATION_ID_PROPERTY, new Long(executionContext.getProcessInstance()
            .getId()).toString());
        props
            .put(ProcessConnector.PROPERTY_PROCESS_STARTED, executionContext.getProcessInstance().getStart());
        if (properties != null)
        {
            props.putAll(properties);
        }

        MuleMessage response = mule.generateMessage(endpoint, payloadObject, props, synchronous);
        if (synchronous)
        {
            if (response != null)
            {
                executionContext.setVariable(ProcessConnector.PROCESS_VARIABLE_INCOMING, response.getPayload());
            }
            else 
            {
                logger.info("Synchronous message was sent to endpoint " + endpoint
                    + ", but no response was returned.");
            }
        }
    }

}