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 [2/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...
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();