accumulatorcomponent.java

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

/*
 * $Id: AccumulatorComponent.java 11968 2008-06-06 04:06:18Z 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.example.scripting;


import org.mule.api.MuleEventContext;
import org.mule.api.lifecycle.Callable;
import org.mule.api.transformer.TransformerException;
import org.mule.config.i18n.MessageFactory;
import org.mule.util.NumberUtils;

/**
 * Component which accumulates successive numbers, by adding/subtracting/multiplying/dividing.  
 */
public class AccumulatorComponent implements Callable
{
    /** Operation to perform: "add", "subtract", "multiply", "divide" */
    private String operation = "add";
    
    private double accumulatedValue = 0;
    
    public Object onCall(MuleEventContext context) throws Exception
    {
        Object msg = context.transformMessage();

        double data = NumberUtils.toDouble(msg);
        if (data == NumberUtils.DOUBLE_ERROR)
        {
            throw new TransformerException(MessageFactory.createStaticMessage("Unable to convert message to double: " + msg));
        }
        
        if (operation.equalsIgnoreCase("add"))
        {
            accumulatedValue += data;
        }
        else if (operation.equalsIgnoreCase("subtract"))
        {
            accumulatedValue -= data;
        }
        else if (operation.equalsIgnoreCase("multiply"))
        {
            accumulatedValue *= data;
        }
        else if (operation.equalsIgnoreCase("divide"))
        {
            accumulatedValue /= data;
        }
        else 
        {
            throw new TransformerException(MessageFactory.createStaticMessage("Operation " + operation + " not recognized"));
        }

        // no auto-boxing
        return new Double(accumulatedValue);
    }

    public String getOperation()
    {
        return operation;
    }

    public void setOperation(String operation)
    {
        this.operation = operation;
    }
}