You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2009/06/05 04:20:29 UTC
svn commit: r781892 - in /camel/trunk/camel-core/src:
main/java/org/apache/camel/ test/java/org/apache/camel/processor/async/
Author: ningjiang
Date: Fri Jun 5 02:20:29 2009
New Revision: 781892
URL: http://svn.apache.org/viewvc?rev=781892&view=rev
Log:
CAMEL-1671 fixed the typo of WaitForTaskToComplete enum
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/WaitForTaskToComplete.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDeadLetterChannelTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDefaultErrorHandlerTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/WaitForTaskToComplete.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/WaitForTaskToComplete.java?rev=781892&r1=781891&r2=781892&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/WaitForTaskToComplete.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/WaitForTaskToComplete.java Fri Jun 5 02:20:29 2009
@@ -32,5 +32,5 @@
@XmlEnum(String.class)
public enum WaitForTaskToComplete {
- Newer, IfReplyExpected, Always
+ Never, IfReplyExpected, Always
}
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDeadLetterChannelTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDeadLetterChannelTest.java?rev=781892&r1=781891&r2=781892&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDeadLetterChannelTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDeadLetterChannelTest.java Fri Jun 5 02:20:29 2009
@@ -79,7 +79,7 @@
errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(2).delay(0).logStackTrace(false));
from("direct:in")
- .threads(2).waitForTaskToComplete(WaitForTaskToComplete.Newer)
+ .threads(2).waitForTaskToComplete(WaitForTaskToComplete.Never)
.to("mock:foo")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDefaultErrorHandlerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDefaultErrorHandlerTest.java?rev=781892&r1=781891&r2=781892&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDefaultErrorHandlerTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncDefaultErrorHandlerTest.java Fri Jun 5 02:20:29 2009
@@ -68,7 +68,7 @@
@Override
public void configure() throws Exception {
from("direct:in")
- .threads(2).waitForTaskToComplete(WaitForTaskToComplete.Newer)
+ .threads(2).waitForTaskToComplete(WaitForTaskToComplete.Never)
.to("mock:foo")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitTest.java?rev=781892&r1=781891&r2=781892&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitTest.java Fri Jun 5 02:20:29 2009
@@ -127,7 +127,7 @@
// we do not want to wait for tasks to be complete so we instruct Camel
// to not wait, and therefore Camel returns the Future<Exchange> handle we
// can use to get the result when we want
- .threads().waitForTaskToComplete(WaitForTaskToComplete.Newer)
+ .threads().waitForTaskToComplete(WaitForTaskToComplete.Never)
// from this point forward this is the async route doing its work
// so we do a bit of delay to simulate heavy work that takes time
.to("mock:foo")
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java?rev=781892&r1=781891&r2=781892&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/async/AsyncRouteNoWaitWithErrorTest.java Fri Jun 5 02:20:29 2009
@@ -104,7 +104,7 @@
// now turn the route into async from this point forward
// the caller will have a Future<Exchange> returned as response in OUT
// to be used to grap the async response when he fell like it
- .threads().waitForTaskToComplete(WaitForTaskToComplete.Newer)
+ .threads().waitForTaskToComplete(WaitForTaskToComplete.Never)
// from this point forward this is the async route doing its work
// so we do a bit of delay to simulate heavy work that takes time
.to("mock:foo")