|
»
« Return to Thread: Re: [mule-scm] [mule] [11723] branches/mule-2.0.x/core/src/main/java/org/mule/util: Add some simple elements to be used by the new scripting example
Re: [mule-scm] [mule] [11723] branches/mule-2.0.x/core/src/m
by Ross Mason-3
::
Rate this Message:
Hi Travis, you've added the sample code to core
On 12 May 2008, at 19:24, tcarlson@... wrote:
- Revision
- 11723
- Author
- tcarlson
- Date
- 2008-05-12 12:24:54 -0500 (Mon, 12 May 2008)
Log Message
Add some simple elements to be used by the new scripting exampleModified Paths
- branches/mule-2.0.x/core/src/main/java/org/mule/util/NumberUtils.java
- branches/mule-2.0.x/modules/spring-config/src/main/java/org/mule/config/spring/handlers/MuleNamespaceHandler.java
- branches/mule-2.0.x/modules/spring-config/src/main/resources/META-INF/mule.xsd
Added Paths
Diff
Added: branches/mule-2.0.x/core/src/main/java/org/mule/component/simple/AccumulatorComponent.java (0 => 11723)
--- branches/mule-2.0.x/core/src/main/java/org/mule/component/simple/AccumulatorComponent.java (rev 0) +++ branches/mule-2.0.x/core/src/main/java/org/mule/component/simple/AccumulatorComponent.java 2008-05-12 17:24:54 UTC (rev 11723) @@ -0,0 +1,72 @@ +/* + * $Id$ + * -------------------------------------------------------------------------------------- + * 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.component.simple; + +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")); + } + + return accumulatedValue; + } + + public String getOperation() + { + return operation; + } + + public void setOperation(String operation) + { + this.operation = operation; + } +} Property changes on: branches/mule-2.0.x/core/src/main/java/org/mule/component/simple/AccumulatorComponent.java ___________________________________________________________________ Name: svn:keywords + Author Date Id Revision Name: svn:eol-style + nativeAdded: branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/SimpleMathTransformer.java (0 => 11723)
--- branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/SimpleMathTransformer.java (rev 0) +++ branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/SimpleMathTransformer.java 2008-05-12 17:24:54 UTC (rev 11723) @@ -0,0 +1,84 @@ +/* + * $Id$ + * -------------------------------------------------------------------------------------- + * 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.transformer.simple; + +import org.mule.api.transformer.TransformerException; +import org.mule.config.i18n.MessageFactory; +import org.mule.transformer.AbstractTransformer; +import org.mule.util.NumberUtils; + +/** + * A simple transformer which adds/subtracts/multiplies/divides a constant factor to integer messages. + */ +public class SimpleMathTransformer extends AbstractTransformer +{ + /** Operation to perform: "add", "subtract", "multiply", "divide" */ + private String operation = "add"; + + /** Factor to be applied */ + private int factor; + + public SimpleMathTransformer() + { + registerSourceType(Number.class); + setReturnClass(Number.class); + } + + public Object doTransform(Object src, String encoding) throws TransformerException + { + double data = NumberUtils.toDouble(src); + if (data == NumberUtils.DOUBLE_ERROR) + { + throw new TransformerException(MessageFactory.createStaticMessage("Unable to convert message to double: " + src)); + } + + if (operation.equalsIgnoreCase("add")) + { + return data + factor; + } + else if (operation.equalsIgnoreCase("subtract")) + { + return data - factor; + } + else if (operation.equalsIgnoreCase("multiply")) + { + return data * factor; + } + else if (operation.equalsIgnoreCase("divide")) + { + return data / factor; + } + else + { + throw new TransformerException(MessageFactory.createStaticMessage("Operation " + operation + " not recognized")); + } + } + + public String getOperation() + { + return operation; + } + + public void setOperation(String operation) + { + this.operation = operation; + } + + public int getFactor() + { + return factor; + } + + public void setFactor(int factor) + { + this.factor = factor; + } +} Property changes on: branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/SimpleMathTransformer.java ___________________________________________________________________ Name: svn:keywords + Author Date Id Revision Name: svn:eol-style + nativeAdded: branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/StringToNumber.java (0 => 11723)
--- branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/StringToNumber.java (rev 0) +++ branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/StringToNumber.java 2008-05-12 17:24:54 UTC (rev 11723) @@ -0,0 +1,52 @@ +/* + * $Id$ + * -------------------------------------------------------------------------------------- + * 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.transformer.simple; + +import org.mule.api.transformer.TransformerException; +import org.mule.transformer.AbstractTransformer; +import org.mule.util.NumberUtils; + +/** + * Converts a string to a number. + */ +public class StringToNumber extends AbstractTransformer +{ + /** Convert the string to an integer (by default it will convert it to a double) */ + private boolean integer = false; + + public StringToNumber() + { + registerSourceType(String.class); + setReturnClass(Number.class); + } + + public Object doTransform(Object src, String encoding) throws TransformerException + { + if (integer) + { + return NumberUtils.toInt(src); + } + else + { + return NumberUtils.toDouble(src); + } + } + + public boolean isInteger() + { + return integer; + } + + public void setInteger(boolean integer) + { + this.integer = integer; + } +} Property changes on: branches/mule-2.0.x/core/src/main/java/org/mule/transformer/simple/StringToNumber.java ___________________________________________________________________ Name: svn:keywords + Author Date Id Revision Name: svn:eol-style + nativeModified: branches/mule-2.0.x/core/src/main/java/org/mule/util/NumberUtils.java (11722 => 11723)
--- branches/mule-2.0.x/core/src/main/java/org/mule/util/NumberUtils.java 2008-05-12 17:20:49 UTC (rev 11722) +++ branches/mule-2.0.x/core/src/main/java/org/mule/util/NumberUtils.java 2008-05-12 17:24:54 UTC (rev 11723) @@ -16,6 +16,10 @@ // @ThreadSafe public class NumberUtils extends org.apache.commons.lang.math.NumberUtils { + public static final int INTEGER_ERROR = -999999999; + public static final long LONG_ERROR = -999999999; + public static final float FLOAT_ERROR = -999999999; + public static final double DOUBLE_ERROR = -999999999; public static long toLong(Object obj) { @@ -59,4 +63,65 @@ } } + public static float toFloat(Object obj) + { + if (obj == null) + { + throw new IllegalArgumentException("Unable to convert null object to float"); + } + else if (obj instanceof String) + { + return toFloat((String) obj); + } + else if (obj instanceof Number) + { + return ((Number) obj).floatValue(); + } + else + { + throw new IllegalArgumentException("Unable to convert object of type: " + + obj.getClass().getName() + " to float."); + } + } + + public static double toDouble(Object obj) + { + if (obj == null) + { + throw new IllegalArgumentException("Unable to convert null object to double"); + } + else if (obj instanceof String) + { + return toDouble((String) obj); + } + else if (obj instanceof Number) + { + return ((Number) obj).doubleValue(); + } + else + { + throw new IllegalArgumentException("Unable to convert object of type: " + + obj.getClass().getName() + " to double."); + } + } + + //@Override + public static int toInt(String str) { + return toInt(str, INTEGER_ERROR); + } + + //@Override + public static long toLong(String str) { + return toLong(str, LONG_ERROR); + } + + //@Override + public static float toFloat(String str) { + return toFloat(str, FLOAT_ERROR); + } + + //@Override + public static double toDouble(String str) { + return toDouble(str, DOUBLE_ERROR); + } }Modified: branches/mule-2.0.x/modules/spring-config/src/main/java/org/mule/config/spring/handlers/MuleNamespaceHandler.java (11722 => 11723)
--- branches/mule-2.0.x/modules/spring-config/src/main/java/org/mule/config/spring/handlers/MuleNamespaceHandler.java 2008-05-12 17:20:49 UTC (rev 11722) +++ branches/mule-2.0.x/modules/spring-config/src/main/java/org/mule/config/spring/handlers/MuleNamespaceHandler.java 2008-05-12 17:24:54 UTC (rev 11723) @@ -14,6 +14,7 @@ import org.mule.component.DefaultJavaComponent; import org.mule.component.PooledJavaComponent; import org.mule.component.SimpleCallableJavaComponent; +import org.mule.component.simple.AccumulatorComponent; import org.mule.component.simple.EchoComponent; import org.mule.component.simple.LogComponent; import org.mule.component.simple.NullComponent; @@ -56,8 +57,8 @@ import org.mule.config.spring.parsers.specific.TransactionManagerDefinitionParser; import org.mule.config.spring.parsers.specific.TransformerDefinitionParser; import org.mule.config.spring.parsers.specific.TransformerRefDefinitionParser; +import org.mule.config.spring.parsers.specific.endpoint.EndpointRefParser; import org.mule.config.spring.parsers.specific.endpoint.GenericEndpointDefinitionParser; -import org.mule.config.spring.parsers.specific.endpoint.EndpointRefParser; import org.mule.config.spring.parsers.specific.endpoint.support.OrphanEndpointDefinitionParser; import org.mule.config.spring.util.SpringBeanLookup; import org.mule.context.notification.ListenerSubscriptionPair; @@ -141,7 +142,9 @@ import org.mule.transformer.simple.ObjectToByteArray; import org.mule.transformer.simple.ObjectToString; import org.mule.transformer.simple.SerializableToByteArray; +import org.mule.transformer.simple.SimpleMathTransformer; import org.mule.transformer.simple.StringAppendTransformer; +import org.mule.transformer.simple.StringToNumber; /** * This is the core namespace handler for Mule and configures all Mule configuration elements under the @@ -215,8 +218,10 @@ registerBeanDefinitionParser("serializable-to-byte-array-transformer", new TransformerDefinitionParser(SerializableToByteArray.class)); registerBeanDefinitionParser("byte-array-to-string-transformer", new TransformerDefinitionParser(ObjectToString.class)); registerBeanDefinitionParser("string-to-byte-array-transformer", new TransformerDefinitionParser(ObjectToByteArray.class)); + registerBeanDefinitionParser("string-to-number-transformer", new TransformerDefinitionParser(StringToNumber.class)); registerBeanDefinitionParser("append-string-transformer", new TransformerDefinitionParser(StringAppendTransformer.class)); + registerBeanDefinitionParser("math-transformer", new TransformerDefinitionParser(SimpleMathTransformer.class)); //Transaction Managers registerBeanDefinitionParser("custom-transaction-manager", new TransactionManagerDefinitionParser()); @@ -268,6 +273,7 @@ registerBeanDefinitionParser("pass-through-component", new ComponentDefinitionParser(PassThroughComponent.class)); registerBeanDefinitionParser("log-component", new SimpleComponentDefinitionParser(SimpleCallableJavaComponent.class, LogComponent.class)); registerBeanDefinitionParser("null-component",new SimpleComponentDefinitionParser(SimpleCallableJavaComponent.class, NullComponent.class)); + registerBeanDefinitionParser("accumulator-component",new SimpleComponentDefinitionParser(SimpleCallableJavaComponent.class, AccumulatorComponent.class)); // We need to use DefaultJavaComponent for the echo comonent because some tests invoke EchoComponent with method name and therefore we need an entry point resolver registerBeanDefinitionParser("echo-component", new SimpleComponentDefinitionParser(DefaultJavaComponent.class, EchoComponent.class));Modified: branches/mule-2.0.x/modules/spring-config/src/main/resources/META-INF/mule.xsd (11722 => 11723)
--- branches/mule-2.0.x/modules/spring-config/src/main/resources/META-INF/mule.xsd 2008-05-12 17:20:49 UTC (rev 11722) +++ branches/mule-2.0.x/modules/spring-config/src/main/resources/META-INF/mule.xsd 2008-05-12 17:24:54 UTC (rev 11723) @@ -1328,7 +1328,15 @@ </xsd:annotation> </xsd:element> + <xsd:element name="accumulator-component" type="defaultComponentType" substitutionGroup="abstract-component"> + <xsd:annotation> + <xsd:documentation> + Component which accumulates successive integers by adding them together. + </xsd:documentation> + </xsd:annotation> + </xsd:element> + <!--==============================================================--> <!-- Transactions --> <!--==============================================================--> @@ -2322,6 +2330,55 @@ </xsd:complexType> </xsd:element> + <xsd:element name="string-to-number-transformer" substitutionGroup="abstract-transformer"> + <xsd:annotation> + <xsd:documentation> + Converts a string to a number. + </xsd:documentation> + </xsd:annotation> + <xsd:complexType> + <xsd:complexContent> + <xsd:extension base="abstractTransformerType"> + <xsd:attribute name="integer" type="substitutableBoolean" use="optional"> + <xsd:annotation> + <xsd:documentation> + Convert the string to an integer (by default it will convert it to a double). + </xsd:documentation> + </xsd:annotation> + </xsd:attribute> + </xsd:extension> + </xsd:complexContent> + </xsd:complexType> + </xsd:element> + + <xsd:element name="math-transformer" substitutionGroup="abstract-transformer"> + <xsd:annotation> + <xsd:documentation> + A simple transformer which adds/subtracts/multiplies/divides a constant factor to integer messages. + </xsd:documentation> + </xsd:annotation> + <xsd:complexType> + <xsd:complexContent> + <xsd:extension base="abstractTransformerType"> + <xsd:attribute name="operation" type="mathematicalOperation" use="required"> + <xsd:annotation> + <xsd:documentation> + The mathematical operation. + </xsd:documentation> + </xsd:annotation> + </xsd:attribute> + <xsd:attribute name="factor" type="xsd:integer" use="required"> + <xsd:annotation> + <xsd:documentation> + Integer factor to be applied to each message. + </xsd:documentation> + </xsd:annotation> + </xsd:attribute> + </xsd:extension> + </xsd:complexContent> + </xsd:complexType> + </xsd:element> + <xsd:element name="encrypt-transformer" type="encryptionTransformerType" substitutionGroup="abstract-transformer"> <xsd:annotation> <xsd:documentation> @@ -3669,6 +3726,14 @@ </xsd:complexContent> </xsd:complexType> + <xsd:simpleType name="mathematicalOperation"> + <xsd:restriction base="xsd:NMTOKEN"> + <xsd:enumeration value="add"/> + <xsd:enumeration value="subtract"/> + <xsd:enumeration value="multiply"/> + <xsd:enumeration value="divide"/> + </xsd:restriction> + </xsd:simpleType> <!--==============================================================--> <!-- Connector support -->To unsubscribe from this list please visit:
« Return to Thread: Re: [mule-scm] [mule] [11723] branches/mule-2.0.x/core/src/main/java/org/mule/util: Add some simple elements to be used by the new scripting example
| Free embeddable forum powered by Nabble | Forum Help |
