Author: davsclaus
Date: Fri Jul 11 04:44:08 2008
New Revision: 675923
URL: http://svn.apache.org/viewvc?rev=675923&view=rev
Log:
Added unit test based on user forum
Added:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithAnnotationAndExchangeTest.java
- copied, changed from r675884,
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithHeaderTest.java
Copied:
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithAnnotationAndExchangeTest.java
(from r675884,
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithHeaderTest.java)
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithAnnotationAndExchangeTest.java?p2=activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithAnnotationAndExchangeTest.java&p1=activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithHeaderTest.java&r1=675884&r2=675923&rev=675923&view=diff
==============================================================================
---
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithHeaderTest.java
(original)
+++
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/component/bean/BeanWithAnnotationAndExchangeTest.java
Fri Jul 11 04:44:08 2008
@@ -18,20 +18,22 @@
import javax.naming.Context;
+import org.apache.camel.Body;
import org.apache.camel.ContextTestSupport;
import org.apache.camel.Exchange;
+import org.apache.camel.Header;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.util.jndi.JndiContext;
/**
- * Unit test to demonstrate the headers can pass through beans.
+ * Unit test to demonstrate annotations combined with Exchange parameter.
*/
-public class BeanWithHeaderTest extends ContextTestSupport {
+public class BeanWithAnnotationAndExchangeTest extends ContextTestSupport {
- public void testBeanWithHeader() throws Exception {
+ public void testBeanWithAnnotationAndExchangeTest() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedBodiesReceived("StartMyBeanMyBean");
+ mock.expectedBodiesReceived("StartMyBean");
mock.expectedHeaderReceived("foo", "bar");
mock.expectedHeaderReceived("user", "admin");
@@ -50,11 +52,7 @@
return new RouteBuilder() {
public void configure() throws Exception {
from("direct:in")
- .setHeader("foo", "bar")
- .to("bean:myBean")
- .to("seda:a");
-
- from("seda:a")
+ .setHeader("user", "admin")
.to("bean:myBean")
.to("mock:result");
}
@@ -62,11 +60,14 @@
}
public static class MyBean {
- public void doSomething(Exchange exchange) {
- String body = exchange.getIn().getBody(String.class);
- exchange.getIn().setHeader("user", "admin");
+
+ // START SNIPPET: e1
+ public void doSomething(@Header(name = "user") String user, @Body
String body, Exchange exchange) {
+ assertEquals("admin", user);
+
exchange.getIn().setBody(body + "MyBean");
}
+ // END SNIPPET: e1
}
-}
+}
\ No newline at end of file