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")
