mulemessageservice.java

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

/*
 * $Id: MuleMessageService.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;

import org.mule.api.MuleMessage;

import java.util.Map;

import org.apache.commons.lang.NotImplementedException;
import org.jbpm.graph.exe.Token;
import org.jbpm.job.Job;

/**
 * jBPM has built-in support for messaging via the org.jbpm.msg.MessageService interface, 
 * the idea being that one can plug in a JMS implementation and send messages from a process 
 * using a standard "<message>" construct.  
 * 
 * If Mule were to implement this interface, one could make Mule the standard MessageService 
 * instead of JMS, which would make the Mule/jBPM integration more "seamless".
 * 
 * This is an unfinished work, see MULE-1219
 */
public class MuleMessageService implements org.jbpm.msg.MessageService
{

    private static final long serialVersionUID = 1L;

    protected static org.mule.transport.bpm.MessageService proxy;

    public MuleMessageService()
    {
        super();
    }

    public static void setMessageService(org.mule.transport.bpm.MessageService msgService)
    {
        proxy = msgService;
    }

    // TODO This should be replaced by the standard send() method below, which would
    // make Mule the default messaging service within jBpm.
    public MuleMessage generateMessage(String endpoint,
                                      Object payloadObject,
                                      Map messageProperties,
                                      boolean synchronous) throws Exception
    {
        return proxy.generateMessage(endpoint, payloadObject, messageProperties, synchronous);
    }

    public void send(Job job) 
    {
        throw new NotImplementedException("MULE-1219");
    }

    public void suspendMessages(Token token)
    {
        // no-op
    }

    public void resumeMessages(Token token)
    {
        // no-op
    }

    public void close()
    {
        // nop-op
    }

}