svn commit: r690707 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java

[davsclaus]

Author: davsclaus
Date: Sun Aug 31 07:35:23 2008
New Revision: 690707

URL: http://svn.apache.org/viewvc?rev=690707&view=rev
Log:
CAMEL-794: Prepared unit test to demonstrate the bug

Modified:
    
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java

Modified: 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java?rev=690707&r1=690706&r2=690707&view=diff
==============================================================================
--- 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java
 (original)
+++ 
activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/BelasThreadErrorHandlerIssue794Test.java
 Sun Aug 31 07:35:23 2008
@@ -65,7 +65,8 @@
         assertEquals(3, counter); // One call + 2 re-deliveries
     }
 
-    public void testThreadErrorHandlerRedeliveryAfterThread() throws Exception 
{
+    public void xtestThreadErrorHandlerRedeliveryAfterThread() throws 
Exception {
+        // TODO: Fix me
         counter = 0;
 
         // We expect the exchange here after 1 delivery and 2 re-deliveries
@@ -79,7 +80,8 @@
         mock.assertIsSatisfied();
     }
 
-    public void testThreadErrorHandlerCallAfterThread() throws Exception {
+    public void xtestThreadErrorHandlerCallAfterThread() throws Exception {
+        // TODO: Fix me
         counter = 0;
 
         template.sendBody("direct:inAfterThread", "Hello World");
@@ -110,11 +112,9 @@
                         }
                     });
 
-                
errorHandler(deadLetterChannel("mock:deafultAfterThread").maximumRedeliveries(2));
                 from("direct:inAfterThread")
                     .thread(2)
-                    // NOTE: this error handler below is not used as we must 
set it before the thread type
-                    
.errorHandler(deadLetterChannel("mock:afterThread").maximumRedeliveries(1))
+                    
.errorHandler(deadLetterChannel("mock:afterThread").maximumRedeliveries(2))
                     .process(new Processor() {
                         public void process(Exchange exchange) throws 
Exception {
                             counter++;