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 2013/10/04 11:37:13 UTC
[1/3] git commit: CAMEL-6810: Fixed bean binding using parameter
syntax style to eager check for compatible types,
which avoids further type conversions which could cause problems with
InputStreams.
Updated Branches:
refs/heads/camel-2.11.x 4b92dcb83 -> 120a2da36
refs/heads/camel-2.12.x 110da9515 -> 70e1c9b02
refs/heads/master a4b7ab2a3 -> 6b2101693
CAMEL-6810: Fixed bean binding using parameter syntax style to eager check for compatible types, which avoids further type conversions which could cause problems with InputStreams.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/6b210169
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6b210169
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6b210169
Branch: refs/heads/master
Commit: 6b21016934b0e39ca7da162d9ce766b1a76ddcb6
Parents: a4b7ab2
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Oct 4 10:56:38 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 4 10:56:38 2013 +0200
----------------------------------------------------------------------
.../apache/camel/component/bean/MethodInfo.java | 21 +--
.../bean/BeanWithInputStreamBodyTest.java | 153 +++++++++++++++++++
2 files changed, 165 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/6b210169/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
index a4dd2e0..0c22e75 100644
--- a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
+++ b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
@@ -393,8 +393,6 @@ public class MethodInfo {
/**
* Returns true if this method is covariant with the specified method
* (this method may above or below the specified method in the class hierarchy)
- * @param method
- * @return
*/
public boolean isCovariantWith(MethodInfo method) {
return
@@ -541,13 +539,18 @@ public class MethodInfo {
return Void.TYPE;
}
- // the parameter value was not already valid, but since the simple language have evaluated the expression
- // which may change the parameterValue, so we have to check it again to see if its now valid
- exp = exchange.getContext().getTypeConverter().convertTo(String.class, parameterValue);
- // String values from the simple language is always valid
- if (!valid) {
- // re validate if the parameter was not valid the first time (String values should be accepted)
- valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ // the parameter value may match the expected type, then we use it as-is
+ if (parameterType.isAssignableFrom(parameterValue.getClass())) {
+ valid = true;
+ } else {
+ // the parameter value was not already valid, but since the simple language have evaluated the expression
+ // which may change the parameterValue, so we have to check it again to see if its now valid
+ exp = exchange.getContext().getTypeConverter().tryConvertTo(String.class, parameterValue);
+ // String values from the simple language is always valid
+ if (!valid) {
+ // re validate if the parameter was not valid the first time (String values should be accepted)
+ valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ }
}
if (valid) {
http://git-wip-us.apache.org/repos/asf/camel/blob/6b210169/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
new file mode 100644
index 0000000..cbf8815
--- /dev/null
+++ b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
@@ -0,0 +1,153 @@
+/**
+ * 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 java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.impl.JndiRegistry;
+
+public class BeanWithInputStreamBodyTest extends ContextTestSupport {
+
+ @Override
+ protected JndiRegistry createRegistry() throws Exception {
+ JndiRegistry jndi = super.createRegistry();
+ jndi.bind("myBean", new MyCoolBean());
+ return jndi;
+ }
+
+ @Override
+ public boolean isUseRouteBuilder() {
+ return false;
+ }
+
+ public void testBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class)
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class, "doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethodOGNL() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething(${body})")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public static final class MyCoolBean {
+
+ public static String doSomething(InputStream is) throws IOException {
+ int byteCount = 0;
+ int c;
+ while ((c = is.read()) != -1) {
+ byteCount++;
+ }
+ return "There is " + byteCount + " bytes";
+ }
+
+ }
+}
[2/3] git commit: CAMEL-6810: Fixed bean binding using parameter
syntax style to eager check for compatible types,
which avoids further type conversions which could cause problems with
InputStreams.
Posted by da...@apache.org.
CAMEL-6810: Fixed bean binding using parameter syntax style to eager check for compatible types, which avoids further type conversions which could cause problems with InputStreams.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/70e1c9b0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/70e1c9b0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/70e1c9b0
Branch: refs/heads/camel-2.12.x
Commit: 70e1c9b0224b02b91a603ab87f12ef01c693c8ab
Parents: 110da95
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Oct 4 10:56:38 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 4 11:09:57 2013 +0200
----------------------------------------------------------------------
.../apache/camel/component/bean/MethodInfo.java | 21 +--
.../bean/BeanWithInputStreamBodyTest.java | 153 +++++++++++++++++++
2 files changed, 165 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/70e1c9b0/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
index a4dd2e0..0c22e75 100644
--- a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
+++ b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
@@ -393,8 +393,6 @@ public class MethodInfo {
/**
* Returns true if this method is covariant with the specified method
* (this method may above or below the specified method in the class hierarchy)
- * @param method
- * @return
*/
public boolean isCovariantWith(MethodInfo method) {
return
@@ -541,13 +539,18 @@ public class MethodInfo {
return Void.TYPE;
}
- // the parameter value was not already valid, but since the simple language have evaluated the expression
- // which may change the parameterValue, so we have to check it again to see if its now valid
- exp = exchange.getContext().getTypeConverter().convertTo(String.class, parameterValue);
- // String values from the simple language is always valid
- if (!valid) {
- // re validate if the parameter was not valid the first time (String values should be accepted)
- valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ // the parameter value may match the expected type, then we use it as-is
+ if (parameterType.isAssignableFrom(parameterValue.getClass())) {
+ valid = true;
+ } else {
+ // the parameter value was not already valid, but since the simple language have evaluated the expression
+ // which may change the parameterValue, so we have to check it again to see if its now valid
+ exp = exchange.getContext().getTypeConverter().tryConvertTo(String.class, parameterValue);
+ // String values from the simple language is always valid
+ if (!valid) {
+ // re validate if the parameter was not valid the first time (String values should be accepted)
+ valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ }
}
if (valid) {
http://git-wip-us.apache.org/repos/asf/camel/blob/70e1c9b0/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
new file mode 100644
index 0000000..cbf8815
--- /dev/null
+++ b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
@@ -0,0 +1,153 @@
+/**
+ * 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 java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.impl.JndiRegistry;
+
+public class BeanWithInputStreamBodyTest extends ContextTestSupport {
+
+ @Override
+ protected JndiRegistry createRegistry() throws Exception {
+ JndiRegistry jndi = super.createRegistry();
+ jndi.bind("myBean", new MyCoolBean());
+ return jndi;
+ }
+
+ @Override
+ public boolean isUseRouteBuilder() {
+ return false;
+ }
+
+ public void testBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class)
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class, "doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethodOGNL() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething(${body})")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public static final class MyCoolBean {
+
+ public static String doSomething(InputStream is) throws IOException {
+ int byteCount = 0;
+ int c;
+ while ((c = is.read()) != -1) {
+ byteCount++;
+ }
+ return "There is " + byteCount + " bytes";
+ }
+
+ }
+}
[3/3] git commit: CAMEL-6810: Fixed bean binding using parameter
syntax style to eager check for compatible types,
which avoids further type conversions which could cause problems with
InputStreams.
Posted by da...@apache.org.
CAMEL-6810: Fixed bean binding using parameter syntax style to eager check for compatible types, which avoids further type conversions which could cause problems with InputStreams.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/120a2da3
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/120a2da3
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/120a2da3
Branch: refs/heads/camel-2.11.x
Commit: 120a2da3601a2f1b227f8ce6137db90d09b3ed47
Parents: 4b92dcb
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Oct 4 10:56:38 2013 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Oct 4 11:10:10 2013 +0200
----------------------------------------------------------------------
.../apache/camel/component/bean/MethodInfo.java | 21 +--
.../bean/BeanWithInputStreamBodyTest.java | 153 +++++++++++++++++++
2 files changed, 165 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/120a2da3/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
index e72aec4..1fe7286 100644
--- a/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
+++ b/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
@@ -389,8 +389,6 @@ public class MethodInfo {
/**
* Returns true if this method is covariant with the specified method
* (this method may above or below the specified method in the class hierarchy)
- * @param method
- * @return
*/
public boolean isCovariantWith(MethodInfo method) {
return
@@ -537,13 +535,18 @@ public class MethodInfo {
return Void.TYPE;
}
- // the parameter value was not already valid, but since the simple language have evaluated the expression
- // which may change the parameterValue, so we have to check it again to see if its now valid
- exp = exchange.getContext().getTypeConverter().convertTo(String.class, parameterValue);
- // String values from the simple language is always valid
- if (!valid) {
- // re validate if the parameter was not valid the first time (String values should be accepted)
- valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ // the parameter value may match the expected type, then we use it as-is
+ if (parameterType.isAssignableFrom(parameterValue.getClass())) {
+ valid = true;
+ } else {
+ // the parameter value was not already valid, but since the simple language have evaluated the expression
+ // which may change the parameterValue, so we have to check it again to see if its now valid
+ exp = exchange.getContext().getTypeConverter().tryConvertTo(String.class, parameterValue);
+ // String values from the simple language is always valid
+ if (!valid) {
+ // re validate if the parameter was not valid the first time (String values should be accepted)
+ valid = parameterValue instanceof String || BeanHelper.isValidParameterValue(exp);
+ }
}
if (valid) {
http://git-wip-us.apache.org/repos/asf/camel/blob/120a2da3/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
----------------------------------------------------------------------
diff --git a/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
new file mode 100644
index 0000000..cbf8815
--- /dev/null
+++ b/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithInputStreamBodyTest.java
@@ -0,0 +1,153 @@
+/**
+ * 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 java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.impl.JndiRegistry;
+
+public class BeanWithInputStreamBodyTest extends ContextTestSupport {
+
+ @Override
+ protected JndiRegistry createRegistry() throws Exception {
+ JndiRegistry jndi = super.createRegistry();
+ jndi.bind("myBean", new MyCoolBean());
+ return jndi;
+ }
+
+ @Override
+ public boolean isUseRouteBuilder() {
+ return false;
+ }
+
+ public void testBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class)
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .bean(MyCoolBean.class, "doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBody() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethod() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public void testToBeanWithInputStreamBodyMethodOGNL() throws Exception {
+ context.addRoutes(new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("direct:start")
+ .to("bean:myBean?method=doSomething(${body})")
+ .to("mock:result");
+ }
+ });
+ context.start();
+
+ getMockEndpoint("mock:result").expectedBodiesReceived("There is 11 bytes");
+
+ InputStream bais = new ByteArrayInputStream("Hello World".getBytes());
+
+ template.sendBody("direct:start", bais);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ public static final class MyCoolBean {
+
+ public static String doSomething(InputStream is) throws IOException {
+ int byteCount = 0;
+ int c;
+ while ((c = is.read()) != -1) {
+ byteCount++;
+ }
+ return "There is " + byteCount + " bytes";
+ }
+
+ }
+}