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/08/30 04:46:51 UTC
svn commit: r1163073 [1/2] - in /camel/trunk:
camel-core/src/test/java/org/apache/camel/processor/async/
components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/
components/camel-jms/src/test/java/org/apache/camel/component/jms/asyn...
Author: hadrian
Date: Tue Aug 30 02:46:48 2011
New Revision: 1163073
URL: http://svn.apache.org/viewvc?rev=1163073&view=rev
Log:
CAMEL-4394. Fix invalid URIs
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCBRTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomAsyncInterceptorTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomInterceptorTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomRoutePolicyTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualMulticastTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualTopicLoadBalanceTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointEventNotifierTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixed3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixedTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceOnlyAsyncTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterDeadLetterChannelTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionContinueTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionHandledTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFilterTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointIdempotentConsumerTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointLoopTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointMulticastTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientList2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelayTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoundRobinLoadBalanceTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSamplingTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaInOnlyTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSingleTopicLoadBalanceTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitFineGrainedErrorHandlingTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitUseLatestAggregationStrategyTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointStopTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousFalseTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTransformTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally2Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally3Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally4Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally5Test.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinallyTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWFailedTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithDelayerTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithHandleFaultTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithTracingTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryAndDelayTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncInOnlyEndpointTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncMDCTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncOnExceptionFailureProcessorWithRedeliveryTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncSedaInOnlyEndpointTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTraceHandlerTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTwoEndpointTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/MyAsyncComponent.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncCBRTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationDisabledTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutOkTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncDefaultContinuationTimeoutTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncFilterTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTransformTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTryCatchFinallyTest.java
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/MyAsyncComponent.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncComponent.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCBRTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCBRTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCBRTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCBRTest.java Tue Aug 30 02:46:48 2011
@@ -59,7 +59,7 @@ public class AsyncEndpointCBRTest extend
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomAsyncInterceptorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomAsyncInterceptorTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomAsyncInterceptorTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomAsyncInterceptorTest.java Tue Aug 30 02:46:48 2011
@@ -68,7 +68,7 @@ public class AsyncEndpointCustomAsyncInt
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomInterceptorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomInterceptorTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomInterceptorTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomInterceptorTest.java Tue Aug 30 02:46:48 2011
@@ -71,7 +71,7 @@ public class AsyncEndpointCustomIntercep
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomRoutePolicyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomRoutePolicyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomRoutePolicyTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointCustomRoutePolicyTest.java Tue Aug 30 02:46:48 2011
@@ -102,7 +102,7 @@ public class AsyncEndpointCustomRoutePol
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualMulticastTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualMulticastTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualMulticastTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualMulticastTest.java Tue Aug 30 02:46:48 2011
@@ -46,7 +46,7 @@ public class AsyncEndpointDualMulticastT
.to("mock:before")
.to("log:before")
.multicast()
- .to("async:Hi Camel").to("async:Bye Camel")
+ .to("async:hi:camel").to("async:bye:camel")
.end()
// fully asynchronous support for multicasting is too complex
// so the main thread will block and wait for both to complete
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualTopicLoadBalanceTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualTopicLoadBalanceTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualTopicLoadBalanceTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointDualTopicLoadBalanceTest.java Tue Aug 30 02:46:48 2011
@@ -45,7 +45,7 @@ public class AsyncEndpointDualTopicLoadB
.to("log:before")
.loadBalance()
.topic()
- .to("async:Bye Camel", "async:Bye World")
+ .to("async:bye:camel", "async:bye:world")
.end()
.to("log:after")
.to("mock:result");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointEventNotifierTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointEventNotifierTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointEventNotifierTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointEventNotifierTest.java Tue Aug 30 02:46:48 2011
@@ -94,7 +94,7 @@ public class AsyncEndpointEventNotifierT
from("direct:start")
.to("mock:before")
- .to("async:Bye Camel?delay=250")
+ .to("async:bye:camel?delay=250")
.to("mock:result");
}
};
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixed3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixed3Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixed3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixed3Test.java Tue Aug 30 02:46:48 2011
@@ -61,7 +61,7 @@ public class AsyncEndpointFailOverLoadBa
.loadBalance()
.failover()
// first is async, the 2nd is sync based
- .to("async:Bye World?failFirstAttempts=5", "direct:ok")
+ .to("async:bye:camel?failFirstAttempts=5", "direct:ok")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixedTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixedTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixedTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceMixedTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncEndpointFailOverLoadBa
.failover()
// the last would succeed
// and make it complex by having a direct endpoint which is not a real async processor
- .to("async:Bye Camel?failFirstAttempts=5", "direct:fail", "async:Bye Moon?failFirstAttempts=5", "async:Bye World")
+ .to("async:bye:camel?failFirstAttempts=5", "direct:fail", "async:Bye Moon?failFirstAttempts=5", "async:Bye World")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceOnlyAsyncTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceOnlyAsyncTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceOnlyAsyncTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailOverLoadBalanceOnlyAsyncTest.java Tue Aug 30 02:46:48 2011
@@ -60,7 +60,7 @@ public class AsyncEndpointFailOverLoadBa
.loadBalance()
.failover()
// the last would succeed
- .to("async:Bye Camel?failFirstAttempts=5", "async:Bye Moon?failFirstAttempts=5", "async:Bye World")
+ .to("async:bye:camel?failFirstAttempts=5", "async:Bye Moon?failFirstAttempts=5", "async:Bye World")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterDeadLetterChannelTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterDeadLetterChannelTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterDeadLetterChannelTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterDeadLetterChannelTest.java Tue Aug 30 02:46:48 2011
@@ -59,7 +59,7 @@ public class AsyncEndpointFailedAfterDea
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionContinueTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionContinueTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionContinueTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionContinueTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncEndpointFailedAfterOnE
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionHandledTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionHandledTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionHandledTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterOnExceptionHandledTest.java Tue Aug 30 02:46:48 2011
@@ -60,7 +60,7 @@ public class AsyncEndpointFailedAfterOnE
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFailedAfterTest.java Tue Aug 30 02:46:48 2011
@@ -63,7 +63,7 @@ public class AsyncEndpointFailedAfterTes
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFilterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFilterTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFilterTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointFilterTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointFilterTest ext
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointIdempotentConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointIdempotentConsumerTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointIdempotentConsumerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointIdempotentConsumerTest.java Tue Aug 30 02:46:48 2011
@@ -69,7 +69,7 @@ public class AsyncEndpointIdempotentCons
}
})
.idempotentConsumer(header("myId"), MemoryIdempotentRepository.memoryIdempotentRepository(200))
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointLoopTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointLoopTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointLoopTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointLoopTest.java Tue Aug 30 02:46:48 2011
@@ -60,7 +60,7 @@ public class AsyncEndpointLoopTest exten
})
.loop(2)
.to("mock:loop")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointMulticastTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointMulticastTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointMulticastTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointMulticastTest.java Tue Aug 30 02:46:48 2011
@@ -56,7 +56,7 @@ public class AsyncEndpointMulticastTest
}
})
.multicast()
- .to("async:Hi Moon", "direct:foo")
+ .to("async:hi:moon", "direct:foo")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointPolicyTest.java Tue Aug 30 02:46:48 2011
@@ -76,7 +76,7 @@ public class AsyncEndpointPolicyTest ext
// wraps the entire route in the same policy
.policy("foo")
.to("mock:foo")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.to("mock:bar")
.to("mock:result");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientList2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientList2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientList2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientList2Test.java Tue Aug 30 02:46:48 2011
@@ -60,7 +60,7 @@ public class AsyncEndpointRecipientList2
.recipientList(constant("direct:foo"));
from("direct:foo")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRecipientListParallel2Test.java Tue Aug 30 02:46:48 2011
@@ -60,7 +60,7 @@ public class AsyncEndpointRecipientListP
.recipientList(constant("direct:foo")).parallelProcessing();
from("direct:foo")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay2Test.java Tue Aug 30 02:46:48 2011
@@ -66,7 +66,7 @@ public class AsyncEndpointRedeliveryErro
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Camel")
+ .to("async:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
LOG.info("Processing at attempt " + attempt + " " + exchange);
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay3Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelay3Test.java Tue Aug 30 02:46:48 2011
@@ -61,7 +61,7 @@ public class AsyncEndpointRedeliveryErro
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?failFirstAttempts=2")
+ .to("async:bye:camel?failFirstAttempts=2")
.to("log:after")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelayTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelayTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelayTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRedeliveryErrorHandlerNonBlockedDelayTest.java Tue Aug 30 02:46:48 2011
@@ -84,7 +84,7 @@ public class AsyncEndpointRedeliveryErro
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoundRobinLoadBalanceTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoundRobinLoadBalanceTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoundRobinLoadBalanceTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointRoundRobinLoadBalanceTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncEndpointRoundRobinLoad
})
.loadBalance()
.roundRobin()
- .to("async:Bye Camel", "async:Bye World")
+ .to("async:bye:camel", "async:Bye World")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSamplingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSamplingTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSamplingTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSamplingTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointSamplingTest e
}
})
.sample()
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.end()
.to("log:after")
.to("mock:after")
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaInOnlyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaInOnlyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaInOnlyTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaInOnlyTest.java Tue Aug 30 02:46:48 2011
@@ -69,7 +69,7 @@ public class AsyncEndpointSedaInOnlyTest
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSedaTest.java Tue Aug 30 02:46:48 2011
@@ -56,7 +56,7 @@ public class AsyncEndpointSedaTest exten
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSingleTopicLoadBalanceTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSingleTopicLoadBalanceTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSingleTopicLoadBalanceTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSingleTopicLoadBalanceTest.java Tue Aug 30 02:46:48 2011
@@ -45,7 +45,7 @@ public class AsyncEndpointSingleTopicLoa
.to("log:before")
.loadBalance()
.topic()
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.end()
.to("log:after")
.to("mock:result");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitFineGrainedErrorHandlingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitFineGrainedErrorHandlingTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitFineGrainedErrorHandlingTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitFineGrainedErrorHandlingTest.java Tue Aug 30 02:46:48 2011
@@ -53,7 +53,7 @@ public class AsyncEndpointSplitFineGrain
from("direct:start")
.split(body())
.to("mock:before")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
if (counter++ == 1) {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitTest.java Tue Aug 30 02:46:48 2011
@@ -56,7 +56,7 @@ public class AsyncEndpointSplitTest exte
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitUseLatestAggregationStrategyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitUseLatestAggregationStrategyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitUseLatestAggregationStrategyTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSplitUseLatestAggregationStrategyTest.java Tue Aug 30 02:46:48 2011
@@ -57,7 +57,7 @@ public class AsyncEndpointSplitUseLatest
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointStopTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointStopTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointStopTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointStopTest.java Tue Aug 30 02:46:48 2011
@@ -57,7 +57,7 @@ public class AsyncEndpointStopTest exten
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousFalseTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousFalseTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousFalseTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousFalseTest.java Tue Aug 30 02:46:48 2011
@@ -57,7 +57,7 @@ public class AsyncEndpointSynchronousFal
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?synchronous=false")
+ .to("async:bye:camel?synchronous=false")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointSynchronousTest.java Tue Aug 30 02:46:48 2011
@@ -57,7 +57,7 @@ public class AsyncEndpointSynchronousTes
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?synchronous=true")
+ .to("async:bye:camel?synchronous=true")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTest.java Tue Aug 30 02:46:48 2011
@@ -57,7 +57,7 @@ public class AsyncEndpointTest extends C
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTransformTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTransformTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTransformTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTransformTest.java Tue Aug 30 02:46:48 2011
@@ -57,9 +57,9 @@ public class AsyncEndpointTransformTest
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Hi Camel")
+ .to("async:hi:camel")
.transform(simple("Hello World"))
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally2Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally2Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally2Test.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncEndpointTryCatchFinall
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?failFirstAttempts=1")
+ .to("async:bye:camel?failFirstAttempts=1")
.doCatch(Exception.class)
.to("log:catch")
.to("mock:catch")
@@ -71,7 +71,7 @@ public class AsyncEndpointTryCatchFinall
middleThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye World")
+ .to("async:bye:world")
.doFinally()
.to("log:finally")
.process(new Processor() {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally3Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally3Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally3Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally3Test.java Tue Aug 30 02:46:48 2011
@@ -70,7 +70,7 @@ public class AsyncEndpointTryCatchFinall
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?failFirstAttempts=1")
+ .to("async:bye:camel?failFirstAttempts=1")
.doCatch(Exception.class)
.to("log:catch")
.to("mock:catch")
@@ -79,7 +79,7 @@ public class AsyncEndpointTryCatchFinall
middleThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye World")
+ .to("async:bye:world")
.doFinally()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
@@ -88,7 +88,7 @@ public class AsyncEndpointTryCatchFinall
})
.to("log:after")
.to("mock:after")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.end()
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally4Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally4Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally4Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally4Test.java Tue Aug 30 02:46:48 2011
@@ -48,10 +48,10 @@ public class AsyncEndpointTryCatchFinall
.to("mock:try")
.doCatch(IllegalArgumentException.class)
.to("mock:catch")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.doFinally()
.to("mock:finally")
- .to("async:Bye World")
+ .to("async:bye:world")
.end()
.to("mock:result");
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally5Test.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally5Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally5Test.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinally5Test.java Tue Aug 30 02:46:48 2011
@@ -51,11 +51,11 @@ public class AsyncEndpointTryCatchFinall
.doCatch(IllegalArgumentException.class)
.to("mock:catch")
.to("log:catch")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.doFinally()
.to("mock:finally")
.to("log:finally")
- .to("async:Bye World")
+ .to("async:bye:world")
.end()
.to("mock:result")
.to("log:result");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinallyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinallyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinallyTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointTryCatchFinallyTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointTryCatchFinall
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel?failFirstAttempts=1")
+ .to("async:bye:camel?failFirstAttempts=1")
.doCatch(Exception.class)
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWFailedTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWFailedTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWFailedTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWFailedTest.java Tue Aug 30 02:46:48 2011
@@ -73,7 +73,7 @@ public class AsyncEndpointUoWFailedTest
})
.to("mock:before")
.to("log:before")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointUoWTest.java Tue Aug 30 02:46:48 2011
@@ -67,7 +67,7 @@ public class AsyncEndpointUoWTest extend
})
.to("mock:before")
.to("log:before")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithDelayerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithDelayerTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithDelayerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithDelayerTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointWithDelayerTes
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithHandleFaultTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithHandleFaultTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithHandleFaultTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithHandleFaultTest.java Tue Aug 30 02:46:48 2011
@@ -65,7 +65,7 @@ public class AsyncEndpointWithHandleFaul
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.to("log:after")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncEndpointWithJMXTest ex
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointWithStreamCach
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithTracingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithTracingTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithTracingTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithTracingTest.java Tue Aug 30 02:46:48 2011
@@ -58,7 +58,7 @@ public class AsyncEndpointWithTracingTes
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryAndDelayTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryAndDelayTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryAndDelayTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryAndDelayTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncFailureProcessorWithRe
})
// invoking the async endpoint could also cause a failure so
// test that we can do redelivery
- .to("async:Bye Camel?failFirstAttempts=2")
+ .to("async:bye:camel?failFirstAttempts=2")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncFailureProcessorWithRedeliveryTest.java Tue Aug 30 02:46:48 2011
@@ -62,7 +62,7 @@ public class AsyncFailureProcessorWithRe
})
// invoking the async endpoint could also cause a failure so
// test that we can do redelivery
- .to("async:Bye Camel?failFirstAttempts=2")
+ .to("async:bye:camel?failFirstAttempts=2")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncInOnlyEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncInOnlyEndpointTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncInOnlyEndpointTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncInOnlyEndpointTest.java Tue Aug 30 02:46:48 2011
@@ -56,7 +56,7 @@ public class AsyncInOnlyEndpointTest ext
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncMDCTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncMDCTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncMDCTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncMDCTest.java Tue Aug 30 02:46:48 2011
@@ -71,7 +71,7 @@ public class AsyncMDCTest extends Contex
}
})
.to("log:before")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.to("log:after")
.to("direct:b");
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncOnExceptionFailureProcessorWithRedeliveryTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncOnExceptionFailureProcessorWithRedeliveryTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncOnExceptionFailureProcessorWithRedeliveryTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncOnExceptionFailureProcessorWithRedeliveryTest.java Tue Aug 30 02:46:48 2011
@@ -66,7 +66,7 @@ public class AsyncOnExceptionFailureProc
})
// invoking the async endpoint could also cause a failure so
// test that we can do redelivery
- .to("async:Bye Camel?failFirstAttempts=2")
+ .to("async:bye:camel?failFirstAttempts=2")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncSedaInOnlyEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncSedaInOnlyEndpointTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncSedaInOnlyEndpointTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncSedaInOnlyEndpointTest.java Tue Aug 30 02:46:48 2011
@@ -56,7 +56,7 @@ public class AsyncSedaInOnlyEndpointTest
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTraceHandlerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTraceHandlerTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTraceHandlerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTraceHandlerTest.java Tue Aug 30 02:46:48 2011
@@ -67,7 +67,7 @@ public class AsyncTraceHandlerTest exten
from("direct:start")
.tracing()
.to("log:before")
- .to("async:Bye Camel").id("async")
+ .to("async:bye:camel").id("async")
.to("log:after")
.to("mock:result");
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTwoEndpointTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTwoEndpointTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTwoEndpointTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncTwoEndpointTest.java Tue Aug 30 02:46:48 2011
@@ -61,7 +61,7 @@ public class AsyncTwoEndpointTest extend
beforeThreadName = Thread.currentThread().getName();
}
})
- .to("async:Hi Camel")
+ .to("async:hi:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
middleThreadName = Thread.currentThread().getName();
@@ -69,7 +69,7 @@ public class AsyncTwoEndpointTest extend
})
.to("log:middle")
.to("mock:middle")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
afterThreadName = Thread.currentThread().getName();
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/MyAsyncComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/MyAsyncComponent.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/MyAsyncComponent.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/MyAsyncComponent.java Tue Aug 30 02:46:48 2011
@@ -29,9 +29,20 @@ public class MyAsyncComponent extends De
@Override
protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
MyAsyncEndpoint answer = new MyAsyncEndpoint(uri, this);
- answer.setReply(remaining);
+ answer.setReply(prepareReply(remaining));
setProperties(answer, parameters);
return answer;
}
+ private String prepareReply(String value) {
+ // to make URIs valid we make the conventions of using ':' for ' ' and
+ // capitalize words
+ String[] words = value.split(":");
+ String result = "";
+ for (String word : words) {
+ result += result.isEmpty() ? "" : " ";
+ result += word.substring(0, 1).toUpperCase() + word.substring(1);
+ }
+ return result;
+ }
}
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncCBRTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncCBRTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncCBRTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncCBRTest.java Tue Aug 30 02:46:48 2011
@@ -46,7 +46,7 @@ public class JettyAsyncCBRTest extends B
.convertBodyTo(String.class)
.choice()
.when(body().contains("Camel"))
- .to("async:Bye World")
+ .to("async:bye:world")
.end()
.to("mock:result");
}
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationDisabledTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationDisabledTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationDisabledTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationDisabledTest.java Tue Aug 30 02:46:48 2011
@@ -43,7 +43,7 @@ public class JettyAsyncContinuationDisab
context.addComponent("async", new MyAsyncComponent());
from("jetty:http://localhost:{{port}}/myservice?useContinuation=false")
- .to("async:Bye World")
+ .to("async:bye:world")
.to("mock:result");
}
};
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutOkTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutOkTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutOkTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutOkTest.java Tue Aug 30 02:46:48 2011
@@ -43,7 +43,7 @@ public class JettyAsyncContinuationTimeo
context.addComponent("async", new MyAsyncComponent());
from("jetty:http://localhost:{{port}}/myservice?continuationTimeout=3000")
- .to("async:Bye World")
+ .to("async:bye:world")
.to("mock:result");
}
};
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncContinuationTimeoutTest.java Tue Aug 30 02:46:48 2011
@@ -59,7 +59,7 @@ public class JettyAsyncContinuationTimeo
context.addComponent("async", new MyAsyncComponent());
from("jetty:http://localhost:{{port}}/myservice?continuationTimeout=3000")
- .to("async:Bye World?delay=6000")
+ .to("async:bye:world?delay=6000")
.to("mock:result");
}
};
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncDefaultContinuationTimeoutTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncDefaultContinuationTimeoutTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncDefaultContinuationTimeoutTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncDefaultContinuationTimeoutTest.java Tue Aug 30 02:46:48 2011
@@ -63,7 +63,7 @@ public class JettyAsyncDefaultContinuati
context.addComponent("async", new MyAsyncComponent());
from("jetty:http://localhost:{{port}}/myservice")
- .to("async:Bye World?delay=45s")
+ .to("async:bye:world?delay=45s")
.to("mock:result");
}
};
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncFilterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncFilterTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncFilterTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncFilterTest.java Tue Aug 30 02:46:48 2011
@@ -45,7 +45,7 @@ public class JettyAsyncFilterTest extend
from("jetty:http://localhost:{{port}}/myservice")
.convertBodyTo(String.class)
.filter(body().contains("Camel"))
- .to("async:Bye World")
+ .to("async:bye:world")
.end()
.to("mock:result");
}
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTest.java Tue Aug 30 02:46:48 2011
@@ -43,7 +43,7 @@ public class JettyAsyncTest extends Base
context.addComponent("async", new MyAsyncComponent());
from("jetty:http://localhost:{{port}}/myservice")
- .to("async:Bye World")
+ .to("async:bye:world")
.to("mock:result");
}
};
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTransformTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTransformTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTransformTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTransformTest.java Tue Aug 30 02:46:48 2011
@@ -46,7 +46,7 @@ public class JettyAsyncTransformTest ext
.to("log:foo")
.convertBodyTo(String.class)
.transform(constant("Hello World"))
- .to("async:Hi World")
+ .to("async:hi:world")
.transform(constant("Bye World"))
.to("mock:result");
}
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTryCatchFinallyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTryCatchFinallyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTryCatchFinallyTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/JettyAsyncTryCatchFinallyTest.java Tue Aug 30 02:46:48 2011
@@ -52,10 +52,10 @@ public class JettyAsyncTryCatchFinallyTe
.throwException(new IllegalArgumentException("Damn"))
.doCatch(IllegalArgumentException.class)
.to("mock:catch")
- .to("async:Bye Camel")
+ .to("async:bye:camel")
.doFinally()
.to("mock:finally")
- .to("async:Bye World")
+ .to("async:bye:world")
.end()
.to("mock:result");
}