You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2011/09/01 02:20:57 UTC
svn commit: r1163876 -
/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/
Author: hadrian
Date: Thu Sep 1 00:20:56 2011
New Revision: 1163876
URL: http://svn.apache.org/viewvc?rev=1163876&view=rev
Log:
CAMEL-4394. Fixed more tests.
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBean4Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBeanTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel4Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel5Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallelTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBeanTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBean4Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBean4Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBean4Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBean4Test.java Thu Sep 1 00:20:56 2011
@@ -57,35 +57,33 @@ public class AsyncEndpointRecipientListB
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .beanRef("myBean");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .beanRef("myBean");
from("direct:foo")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- exchange.getOut().setBody("Bye Camel");
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ exchange.getOut().setBody("Bye Camel");
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
public static class MyRecipientBean {
-
@RecipientList
public String doSomething() {
- return "async:Hi Camel,async:Hi World,direct:foo";
+ return "async:hi:camel,async:hi:world,direct:foo";
}
}
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBeanTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBeanTest.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBeanTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListBeanTest.java Thu Sep 1 00:20:56 2011
@@ -57,32 +57,30 @@ public class AsyncEndpointRecipientListB
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .beanRef("myBean")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .beanRef("myBean")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
public static class MyRecipientBean {
-
@RecipientList
public String doSomething() {
- return "async:Bye Camel";
+ return "async:bye:camel";
}
}
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel3Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel3Test.java Thu Sep 1 00:20:56 2011
@@ -50,25 +50,25 @@ public class AsyncEndpointRecipientListP
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .recipientList(constant("async:Hi Camel?delay=200,direct:foo")).parallelProcessing();
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .recipientList(constant("async:hi:camel?delay=200,direct:foo")).parallelProcessing();
from("direct:foo")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- exchange.getOut().setBody("Bye Camel");
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ exchange.getOut().setBody("Bye Camel");
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel4Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel4Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel4Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel4Test.java Thu Sep 1 00:20:56 2011
@@ -50,25 +50,25 @@ public class AsyncEndpointRecipientListP
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .recipientList(constant("async:Hi Camel,async:Hi World,direct:foo")).parallelProcessing();
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .recipientList(constant("async:hi:camel,async:hi:world,direct:foo")).parallelProcessing();
from("direct:foo")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- exchange.getOut().setBody("Bye Camel");
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ exchange.getOut().setBody("Bye Camel");
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel5Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel5Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel5Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel5Test.java Thu Sep 1 00:20:56 2011
@@ -51,27 +51,27 @@ public class AsyncEndpointRecipientListP
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .recipientList(constant("async:Hi Camel,async:Hi World,direct:foo")).parallelProcessing()
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .recipientList(constant("async:hi:camel,async:hi:world,direct:foo")).parallelProcessing()
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
from("direct:foo")
- .transform(constant("Bye Camel"))
- .to("mock:foo");
+ .transform(constant("Bye Camel"))
+ .to("mock:foo");
}
};
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallelTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallelTest.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallelTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallelTest.java Thu Sep 1 00:20:56 2011
@@ -49,22 +49,22 @@ public class AsyncEndpointRecipientListP
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .recipientList(constant("async:Bye Camel")).parallelProcessing()
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .recipientList(constant("async:bye:camel")).parallelProcessing()
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListTest.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListTest.java Thu Sep 1 00:20:56 2011
@@ -48,24 +48,23 @@ public class AsyncEndpointRecipientListT
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .recipientList(constant("async:Bye Camel"))
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .recipientList(constant("async:bye:camel"))
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip2Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip2Test.java Thu Sep 1 00:20:56 2011
@@ -37,9 +37,8 @@ public class AsyncEndpointRoutingSlip2Te
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .routingSlip(constant("async:Bye Camel,async:Bye World"));
+ .routingSlip(constant("async:bye:camel,async:bye:world"));
}
};
}
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip3Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlip3Test.java Thu Sep 1 00:20:56 2011
@@ -50,29 +50,28 @@ public class AsyncEndpointRoutingSlip3Te
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .routingSlip(constant("async:Hi World,direct:foo"));
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .routingSlip(constant("async:hi:world, direct:foo"));
from("direct:foo")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- String body = exchange.getIn().getBody(String.class);
- assertEquals("Hi World", body);
- exchange.getOut().setBody("Bye Camel");
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ String body = exchange.getIn().getBody(String.class);
+ assertEquals("Hi World", body);
+ exchange.getOut().setBody("Bye Camel");
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean2Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean2Test.java Thu Sep 1 00:20:56 2011
@@ -46,7 +46,7 @@ public class AsyncEndpointRoutingSlipBea
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .beanRef("myBean");
+ .beanRef("myBean");
}
};
}
@@ -55,9 +55,7 @@ public class AsyncEndpointRoutingSlipBea
@RoutingSlip
public String doSomething() {
- return "async:Bye Camel,async:Bye World";
+ return "async:bye:camel,async:bye:world";
}
}
-
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean3Test.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBean3Test.java Thu Sep 1 00:20:56 2011
@@ -59,27 +59,27 @@ public class AsyncEndpointRoutingSlipBea
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .to("mock:before")
- .to("log:before")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- beforeThreadName = Thread.currentThread().getName();
- }
- })
- .beanRef("myBean");
+ .to("mock:before")
+ .to("log:before")
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ beforeThreadName = Thread.currentThread().getName();
+ }
+ })
+ .beanRef("myBean");
from("direct:foo")
- .process(new Processor() {
- public void process(Exchange exchange) throws Exception {
- afterThreadName = Thread.currentThread().getName();
- String body = exchange.getIn().getBody(String.class);
- assertEquals("Hi World", body);
- exchange.getOut().setBody("Bye Camel");
- }
- })
- .to("log:after")
- .to("mock:after")
- .to("mock:result");
+ .process(new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ afterThreadName = Thread.currentThread().getName();
+ String body = exchange.getIn().getBody(String.class);
+ assertEquals("Hi World", body);
+ exchange.getOut().setBody("Bye Camel");
+ }
+ })
+ .to("log:after")
+ .to("mock:after")
+ .to("mock:result");
}
};
}
@@ -88,9 +88,7 @@ public class AsyncEndpointRoutingSlipBea
@RoutingSlip
public String doSomething() {
- return "async:Hi World,direct:foo";
+ return "async:hi:world,direct:foo";
}
}
-
-
}
\ No newline at end of file
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBeanTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBeanTest.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBeanTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipBeanTest.java Thu Sep 1 00:20:56 2011
@@ -50,7 +50,7 @@ public class AsyncEndpointRoutingSlipBea
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .beanRef("myBean");
+ .beanRef("myBean");
}
};
}
@@ -59,7 +59,7 @@ public class AsyncEndpointRoutingSlipBea
@RoutingSlip
public String doSomething() {
- return "async:Bye Camel,mock:result";
+ return "async:bye:camel,mock:result";
}
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipTest.java?rev=1163876&r1=1163875&r2=1163876&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoutingSlipTest.java Thu Sep 1 00:20:56 2011
@@ -41,7 +41,7 @@ public class AsyncEndpointRoutingSlipTes
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
- .routingSlip(constant("async:Bye Camel,mock:result"));
+ .routingSlip(constant("async:bye:camel,mock:result"));
}
};
}