You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2011/09/22 12:35:59 UTC
svn commit: r1174047 - in /camel/trunk:
camel-core/src/main/java/org/apache/camel/component/bean/
camel-core/src/main/java/org/apache/camel/language/bean/
camel-core/src/main/java/org/apache/camel/model/
camel-core/src/main/java/org/apache/camel/model/...
Author: davsclaus
Date: Thu Sep 22 10:35:58 2011
New Revision: 1174047
URL: http://svn.apache.org/viewvc?rev=1174047&view=rev
Log:
CAMEL-4386: Method call expression can now invoke static methods as well. 2nd part of this ticket.
Added:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java (contents, props changed)
- copied, changed from r1173948, camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanHolder.java
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantTypeBeanHolder.java
- copied, changed from r1173948, camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java
camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/RouteMethodCallStaticTest.java
camel/trunk/components/camel-spring/src/test/java/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.java
camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml
- copied, changed from r1174013, camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/beanBindingTest.xml
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java
camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodNotFoundException.java
camel/trunk/camel-core/src/main/java/org/apache/camel/language/bean/BeanExpression.java
camel/trunk/camel-core/src/main/java/org/apache/camel/model/BeanDefinition.java
camel/trunk/camel-core/src/main/java/org/apache/camel/model/language/MethodCallExpression.java
camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/MyStaticClass.java
Copied: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java (from r1173948, camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanHolder.java)
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java?p2=camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java&p1=camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanHolder.java&r1=1173948&r2=1174047&rev=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanHolder.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java Thu Sep 22 10:35:58 2011
@@ -16,19 +16,13 @@
*/
package org.apache.camel.component.bean;
-import org.apache.camel.NoSuchBeanException;
-import org.apache.camel.Processor;
-
/**
- * Object holder for a bean.
+ * Object holder for a bean type.
*
* @version
*/
-public interface BeanHolder {
-
- Object getBean() throws NoSuchBeanException;
+public interface BeanTypeHolder extends BeanHolder {
- Processor getProcessor();
+ Class<?> getType();
- BeanInfo getBeanInfo();
}
Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/BeanTypeHolder.java
------------------------------------------------------------------------------
svn:keywords = Rev Date
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java Thu Sep 22 10:35:58 2011
@@ -19,6 +19,7 @@ package org.apache.camel.component.bean;
import org.apache.camel.CamelContext;
import org.apache.camel.Processor;
import org.apache.camel.util.CamelContextHelper;
+import org.apache.camel.util.ObjectHelper;
/**
* A constant (singleton) bean implementation of {@link BeanHolder}
@@ -31,6 +32,9 @@ public class ConstantBeanHolder implemen
private final Processor processor;
public ConstantBeanHolder(Object bean, BeanInfo beanInfo) {
+ ObjectHelper.notNull(bean, "bean");
+ ObjectHelper.notNull(beanInfo, "beanInfo");
+
this.bean = bean;
this.beanInfo = beanInfo;
this.processor = CamelContextHelper.convertTo(beanInfo.getCamelContext(), Processor.class, bean);
Copied: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantTypeBeanHolder.java (from r1173948, camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java)
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantTypeBeanHolder.java?p2=camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantTypeBeanHolder.java&p1=camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java&r1=1173948&r2=1174047&rev=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantBeanHolder.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/ConstantTypeBeanHolder.java Thu Sep 22 10:35:58 2011
@@ -18,46 +18,52 @@ package org.apache.camel.component.bean;
import org.apache.camel.CamelContext;
import org.apache.camel.Processor;
-import org.apache.camel.util.CamelContextHelper;
+import org.apache.camel.util.ObjectHelper;
/**
- * A constant (singleton) bean implementation of {@link BeanHolder}
+ * A constant (singleton) bean implementation of {@link org.apache.camel.component.bean.BeanTypeHolder}
*
- * @version
+ * @version
*/
-public class ConstantBeanHolder implements BeanHolder {
- private final Object bean;
+public class ConstantTypeBeanHolder implements BeanTypeHolder {
+ private final Class<?> type;
private final BeanInfo beanInfo;
- private final Processor processor;
- public ConstantBeanHolder(Object bean, BeanInfo beanInfo) {
- this.bean = bean;
+ public ConstantTypeBeanHolder(Class<?> type, BeanInfo beanInfo) {
+ ObjectHelper.notNull(type, "type");
+ ObjectHelper.notNull(beanInfo, "beanInfo");
+
+ this.type = type;
this.beanInfo = beanInfo;
- this.processor = CamelContextHelper.convertTo(beanInfo.getCamelContext(), Processor.class, bean);
}
- public ConstantBeanHolder(Object bean, CamelContext context) {
- this(bean, new BeanInfo(context, bean.getClass()));
+ public ConstantTypeBeanHolder(Class<?> type, CamelContext context) {
+ this(type, new BeanInfo(context, type));
}
- public ConstantBeanHolder(Object bean, CamelContext context, ParameterMappingStrategy parameterMappingStrategy) {
- this(bean, new BeanInfo(context, bean.getClass(), parameterMappingStrategy));
+ public ConstantTypeBeanHolder(Class<?> type, CamelContext context, ParameterMappingStrategy parameterMappingStrategy) {
+ this(type, new BeanInfo(context, type, parameterMappingStrategy));
}
@Override
public String toString() {
- return bean.toString();
+ return type.toString();
}
public Object getBean() {
- return bean;
+ return null;
}
public Processor getProcessor() {
- return processor;
+ return null;
}
public BeanInfo getBeanInfo() {
return beanInfo;
}
+
+ public Class<?> getType() {
+ return type;
+ }
+
}
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodNotFoundException.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodNotFoundException.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodNotFoundException.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodNotFoundException.java Thu Sep 22 10:35:58 2011
@@ -36,7 +36,7 @@ public class MethodNotFoundException ext
this.bean = pojo;
}
- public MethodNotFoundException(Exchange exchange, Class type, String methodName, boolean isStaticMethod) {
+ public MethodNotFoundException(Exchange exchange, Class<?> type, String methodName, boolean isStaticMethod) {
super((isStaticMethod ? "Static method" : "Method") + " with name: " + methodName + " not found on class: " + ObjectHelper.name(type), exchange);
this.methodName = methodName;
this.bean = null;
@@ -48,6 +48,12 @@ public class MethodNotFoundException ext
this.bean = pojo;
}
+ public MethodNotFoundException(Class<?> type, String methodName, Throwable cause) {
+ super("Method with name: " + methodName + " not found on class: " + ObjectHelper.className(type), null, cause);
+ this.methodName = methodName;
+ this.bean = null;
+ }
+
public String getMethodName() {
return methodName;
}
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/language/bean/BeanExpression.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/language/bean/BeanExpression.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/language/bean/BeanExpression.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/language/bean/BeanExpression.java Thu Sep 22 10:35:58 2011
@@ -28,6 +28,7 @@ import org.apache.camel.Processor;
import org.apache.camel.component.bean.BeanHolder;
import org.apache.camel.component.bean.BeanProcessor;
import org.apache.camel.component.bean.ConstantBeanHolder;
+import org.apache.camel.component.bean.ConstantTypeBeanHolder;
import org.apache.camel.component.bean.RegistryBean;
import org.apache.camel.util.KeyValueHolder;
import org.apache.camel.util.ObjectHelper;
@@ -40,9 +41,10 @@ import org.apache.camel.util.StringHelpe
* @version
*/
public class BeanExpression implements Expression, Predicate {
+ private Object bean;
private String beanName;
+ private Class<?> type;
private String method;
- private Object bean;
public BeanExpression(Object bean, String method) {
this.bean = bean;
@@ -54,18 +56,39 @@ public class BeanExpression implements E
this.method = method;
}
+ public BeanExpression(Class<?> type, String method) {
+ this.type = type;
+ this.method = method;
+ }
+
@Override
public String toString() {
- return "BeanExpression[bean:" + (bean == null ? beanName : bean) + " method: " + method + "]";
+ StringBuilder sb = new StringBuilder("BeanExpression[");
+ if (bean != null) {
+ sb.append(bean.toString());
+ } else if (beanName != null) {
+ sb.append(beanName);
+ } else if (type != null) {
+ sb.append(ObjectHelper.className(type));
+ }
+ if (method != null) {
+ sb.append(" method: ").append(method);
+ }
+ sb.append("]");
+ return sb.toString();
}
public Object evaluate(Exchange exchange) {
// either use registry lookup or a constant bean
BeanHolder holder;
- if (bean == null) {
+ if (bean != null) {
+ holder = new ConstantBeanHolder(bean, exchange.getContext());
+ } else if (beanName != null) {
holder = new RegistryBean(exchange.getContext(), beanName);
+ } else if (type != null) {
+ holder = new ConstantTypeBeanHolder(type, exchange.getContext());
} else {
- holder = new ConstantBeanHolder(bean, exchange.getContext());
+ throw new IllegalArgumentException("Either bean, beanName or type should be set on " + this);
}
// invoking the bean can either be the easy way or using OGNL
@@ -78,8 +101,7 @@ public class BeanExpression implements E
if (OgnlHelper.isValidOgnlExpression(method)) {
// okay the method is an ognl expression
- Object beanToCall = holder.getBean();
- OgnlInvokeProcessor ognl = new OgnlInvokeProcessor(beanToCall, method);
+ OgnlInvokeProcessor ognl = new OgnlInvokeProcessor(holder, method);
try {
ognl.process(exchange);
return ognl.getResult();
@@ -159,15 +181,15 @@ public class BeanExpression implements E
*/
private final class OgnlInvokeProcessor implements Processor {
- private final Object bean;
private final String ognl;
+ private final BeanHolder beanHolder;
private Object result;
- public OgnlInvokeProcessor(Object bean, String ognl) {
- this.bean = bean;
+ public OgnlInvokeProcessor(BeanHolder beanHolder, String ognl) {
+ this.beanHolder = beanHolder;
this.ognl = ognl;
// we must start with having bean as the result
- this.result = bean;
+ this.result = beanHolder.getBean();
}
public void process(Exchange exchange) throws Exception {
@@ -183,7 +205,11 @@ public class BeanExpression implements E
String ognlPath = "";
// loop and invoke each method
- Object beanToCall = bean;
+ Object beanToCall = beanHolder.getBean();
+ // there must be a bean to call with, we currently does not support OGNL expressions on using purely static methods
+ if (beanToCall == null) {
+ throw new IllegalArgumentException("Bean instance is null. OGNL bean expressions requires bean instances.");
+ }
// Split ognl except when this is not a Map, Array
// and we would like to keep the dots within the key name
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/BeanDefinition.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/BeanDefinition.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/BeanDefinition.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/BeanDefinition.java Thu Sep 22 10:35:58 2011
@@ -23,9 +23,11 @@ import javax.xml.bind.annotation.XmlRoot
import javax.xml.bind.annotation.XmlTransient;
import org.apache.camel.Processor;
+import org.apache.camel.component.bean.BeanHolder;
import org.apache.camel.component.bean.BeanInfo;
import org.apache.camel.component.bean.BeanProcessor;
import org.apache.camel.component.bean.ConstantBeanHolder;
+import org.apache.camel.component.bean.ConstantTypeBeanHolder;
import org.apache.camel.component.bean.MethodNotFoundException;
import org.apache.camel.component.bean.RegistryBean;
import org.apache.camel.spi.Required;
@@ -172,10 +174,10 @@ public class BeanDefinition extends NoOu
public Processor createProcessor(RouteContext routeContext) {
BeanProcessor answer;
Class<?> clazz = bean != null ? bean.getClass() : null;
- BeanInfo beanInfo = null;
+ BeanHolder beanHolder;
if (ObjectHelper.isNotEmpty(ref)) {
- RegistryBean beanHolder = new RegistryBean(routeContext.getCamelContext(), ref);
+ beanHolder = new RegistryBean(routeContext.getCamelContext(), ref);
// bean holder will check if the bean exists
bean = beanHolder.getBean();
answer = new BeanProcessor(beanHolder);
@@ -201,33 +203,31 @@ public class BeanDefinition extends NoOu
+ ". We suppose you want to refer to a bean instance by its id instead. Please use beanRef.");
}
- // notice bean may be null if its a static class
- beanInfo = new BeanInfo(routeContext.getCamelContext(), clazz);
- answer = new BeanProcessor(new ConstantBeanHolder(bean, beanInfo));
+ // the holder should either be bean or type based
+ beanHolder = bean != null ? new ConstantBeanHolder(bean, routeContext.getCamelContext()) : new ConstantTypeBeanHolder(clazz, routeContext.getCamelContext());
+ answer = new BeanProcessor(beanHolder);
}
+
+ // check for method exists
if (method != null) {
answer.setMethod(method);
// check there is a method with the given name, and leverage BeanInfo for that
- if (bean != null) {
- clazz = bean.getClass();
- }
- if (beanInfo == null) {
- beanInfo = new BeanInfo(routeContext.getCamelContext(), clazz);
- }
-
+ BeanInfo beanInfo = beanHolder.getBeanInfo();
if (bean != null) {
// there is a bean instance, so check for any methods
if (!beanInfo.hasMethod(method)) {
throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(null, bean, method));
}
- } else {
+ } else if (clazz != null) {
// there is no bean instance, so check for static methods only
if (!beanInfo.hasStaticMethod(method)) {
throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(null, clazz, method, true));
}
}
}
+
return answer;
}
+
}
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/language/MethodCallExpression.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/language/MethodCallExpression.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/model/language/MethodCallExpression.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/language/MethodCallExpression.java Thu Sep 22 10:35:58 2011
@@ -31,6 +31,7 @@ import org.apache.camel.component.bean.B
import org.apache.camel.component.bean.MethodNotFoundException;
import org.apache.camel.component.bean.RegistryBean;
import org.apache.camel.language.bean.BeanExpression;
+import org.apache.camel.util.CamelContextHelper;
import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.OgnlHelper;
@@ -154,8 +155,13 @@ public class MethodCallExpression extend
}
if (beanType != null) {
- instance = camelContext.getInjector().newInstance(beanType);
- answer = new BeanExpression(instance, getMethod());
+ // create a bean if there is a default public no-arg constructor
+ if (ObjectHelper.hasDefaultPublicNoArgConstructor(beanType)) {
+ instance = camelContext.getInjector().newInstance(beanType);
+ answer = new BeanExpression(instance, getMethod());
+ } else {
+ answer = new BeanExpression(beanType, getMethod());
+ }
} else if (instance != null) {
answer = new BeanExpression(instance, getMethod());
} else {
@@ -167,7 +173,7 @@ public class MethodCallExpression extend
answer = new BeanExpression(ref, getMethod());
}
- validateHasMethod(camelContext, instance, getMethod());
+ validateHasMethod(camelContext, instance, beanType, getMethod());
return answer;
}
@@ -183,14 +189,19 @@ public class MethodCallExpression extend
*
* @param context camel context
* @param bean the bean instance
+ * @param type the bean type
* @param method the method, can be <tt>null</tt> if no method name provided
* @throws org.apache.camel.RuntimeCamelException is thrown if bean does not have the method
*/
- protected void validateHasMethod(CamelContext context, Object bean, String method) {
+ protected void validateHasMethod(CamelContext context, Object bean, Class<?> type, String method) {
if (method == null) {
return;
}
+ if (bean == null && type == null) {
+ throw new IllegalArgumentException("Either bean or type should be provided on " + this);
+ }
+
// do not try to validate ognl methods
if (OgnlHelper.isValidOgnlExpression(method)) {
return;
@@ -199,12 +210,20 @@ public class MethodCallExpression extend
// if invalid OGNL then fail
if (OgnlHelper.isInvalidValidOgnlExpression(method)) {
ExpressionIllegalSyntaxException cause = new ExpressionIllegalSyntaxException(method);
- throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(bean, method, cause));
+ throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(bean != null ? bean : type, method, cause));
}
- BeanInfo info = new BeanInfo(context, bean.getClass());
- if (!info.hasMethod(method)) {
- throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(null, bean, method));
+ if (bean != null) {
+ BeanInfo info = new BeanInfo(context, bean.getClass());
+ if (!info.hasMethod(method)) {
+ throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(null, bean, method));
+ }
+ } else {
+ BeanInfo info = new BeanInfo(context, type);
+ // must be a static method as we do not have a bean instance to invoke
+ if (!info.hasStaticMethod(method)) {
+ throw ObjectHelper.wrapRuntimeCamelException(new MethodNotFoundException(null, type, method, true));
+ }
}
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/MyStaticClass.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/MyStaticClass.java?rev=1174047&r1=1174046&r2=1174047&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/MyStaticClass.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/MyStaticClass.java Thu Sep 22 10:35:58 2011
@@ -31,6 +31,10 @@ public final class MyStaticClass {
return null;
}
+ public static boolean isCamel(String body) {
+ return body.contains("Camel");
+ }
+
public void doSomething() {
// noop
}
Added: camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/RouteMethodCallStaticTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/RouteMethodCallStaticTest.java?rev=1174047&view=auto
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/RouteMethodCallStaticTest.java (added)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/RouteMethodCallStaticTest.java Thu Sep 22 10:35:58 2011
@@ -0,0 +1,51 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.bean;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.builder.RouteBuilder;
+
+/**
+ *
+ */
+public class RouteMethodCallStaticTest extends ContextTestSupport {
+
+ public void testStaticMethodCall() throws Exception {
+ getMockEndpoint("mock:camel").expectedBodiesReceived("Hello Camel");
+ getMockEndpoint("mock:other").expectedBodiesReceived("Hello World");
+
+ template.sendBody("direct:start", "Hello World");
+ template.sendBody("direct:start", "Hello Camel");
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .choice()
+ .when().method(MyStaticClass.class, "isCamel")
+ .to("mock:camel")
+ .otherwise()
+ .to("mock:other");
+ }
+ };
+ }
+}
Added: camel/trunk/components/camel-spring/src/test/java/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/java/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.java?rev=1174047&view=auto
==============================================================================
--- camel/trunk/components/camel-spring/src/test/java/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.java (added)
+++ camel/trunk/components/camel-spring/src/test/java/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.java Thu Sep 22 10:35:58 2011
@@ -0,0 +1,31 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.bean;
+
+import org.apache.camel.CamelContext;
+
+import static org.apache.camel.spring.processor.SpringTestHelper.createSpringCamelContext;
+
+/**
+ *
+ */
+public class SpringRouteMethodCallStaticTest extends RouteMethodCallStaticTest {
+
+ protected CamelContext createCamelContext() throws Exception {
+ return createSpringCamelContext(this, "org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml");
+ }
+}
Copied: camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml (from r1174013, camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/beanBindingTest.xml)
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml?p2=camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml&p1=camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/beanBindingTest.xml&r1=1174013&r2=1174047&rev=1174047&view=diff
==============================================================================
--- camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/beanBindingTest.xml (original)
+++ camel/trunk/components/camel-spring/src/test/resources/org/apache/camel/component/bean/SpringRouteMethodCallStaticTest.xml Thu Sep 22 10:35:58 2011
@@ -22,14 +22,19 @@
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
">
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <template id="template"/>
- </camelContext>
-
- <bean id="myConsumer" class="org.apache.camel.component.bean.MyBeanBindingConsumer">
- <property name="template" ref="template"/>
- </bean>
-
- <bean id="myCounter" class="org.apache.camel.component.bean.MyBeanCounter"/>
+ <camelContext xmlns="http://camel.apache.org/schema/spring">
+ <route>
+ <from uri="direct:start"/>
+ <choice>
+ <when>
+ <method beanType="org.apache.camel.component.bean.MyStaticClass" method="isCamel"/>
+ <to uri="mock:camel"/>
+ </when>
+ <otherwise>
+ <to uri="mock:other"/>
+ </otherwise>
+ </choice>
+ </route>
+ </camelContext>
</beans>