Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/MyAsyncComponent.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/MyAsyncComponent.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/async/MyAsyncComponent.java (original) +++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/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-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncComponent.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncComponent.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/async/MyAsyncComponent.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/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-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTX2Test.java Tue Aug 30 02:46:48 2011 @@ -74,7 +74,7 @@ public class AsyncEndpointJmsTX2Test ext assertTrue("Exchange should be transacted", exchange.isTransacted()); } }) - .to("async:Hi Camel") + .to("async:hi:camel") .process(new Processor() { public void process(Exchange exchange) throws Exception { afterThreadName = Thread.currentThread().getName(); @@ -89,7 +89,7 @@ public class AsyncEndpointJmsTX2Test ext from("direct:foo") .transacted() - .to("async:Bye Camel"); + .to("async:bye:camel"); } }; } Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXMulticastTest.java Tue Aug 30 02:46:48 2011 @@ -79,7 +79,7 @@ public class AsyncEndpointJmsTXMulticast from("direct:foo") // tx should be conveyed to this route as well - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRecipientListTest.java Tue Aug 30 02:46:48 2011 @@ -78,7 +78,7 @@ public class AsyncEndpointJmsTXRecipient from("direct:foo") // tx should be conveyed to this route as well - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollback2Test.java Tue Aug 30 02:46:48 2011 @@ -79,7 +79,7 @@ public class AsyncEndpointJmsTXRollback2 assertTrue("Exchange should be transacted", exchange.isTransacted()); } }) - .to("async:Hi Camel") + .to("async:hi:camel") .process(new Processor() { public void process(Exchange exchange) throws Exception { afterThreadName = Thread.currentThread().getName(); @@ -93,7 +93,7 @@ public class AsyncEndpointJmsTXRollback2 from("direct:foo") .transacted() - .to("async:Bye Camel") + .to("async:bye:camel") .process(new Processor() { public void process(Exchange exchange) throws Exception { invoked++; Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRollbackTest.java Tue Aug 30 02:46:48 2011 @@ -78,7 +78,7 @@ public class AsyncEndpointJmsTXRollbackT assertTrue("Exchange should be transacted", exchange.isTransacted()); } }) - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXRoutingSlipTest.java Tue Aug 30 02:46:48 2011 @@ -79,7 +79,7 @@ public class AsyncEndpointJmsTXRoutingSl from("direct:foo") // tx should be conveyed to this route as well - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTest.java Tue Aug 30 02:46:48 2011 @@ -74,7 +74,7 @@ public class AsyncEndpointJmsTXTest exte assertTrue("Exchange should be transacted", exchange.isTransacted()); } }) - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXTryCatchFinallyTest.java Tue Aug 30 02:46:48 2011 @@ -88,7 +88,7 @@ public class AsyncEndpointJmsTXTryCatchF from("direct:foo") // tx should be conveyed to this route as well - .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/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java?rev=1163073&r1=1163072&r2=1163073&view=diff ============================================================================== --- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java (original) +++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/AsyncEndpointJmsTXWireTapTest.java Tue Aug 30 02:46:48 2011 @@ -71,7 +71,7 @@ public class AsyncEndpointJmsTXWireTapTe assertTrue("Exchange should be transacted", exchange.isTransacted()); } }) - .to("async:Bye Camel") + .to("async:bye:camel") .wireTap("direct:tap") .to("mock:result"); @@ -82,7 +82,7 @@ public class AsyncEndpointJmsTXWireTapTe assertFalse("Exchange should NOT be transacted", exchange.isTransacted()); } }) - .to("async:Hi Camel") + .to("async:hi:camel") .process(new Processor() { public void process(Exchange exchange) throws Exception { afterThreadName = Thread.currentThread().getName();
