You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/05/13 09:21:23 UTC

svn commit: r943830 - in /camel/trunk/camel-core/src/main/java/org/apache/camel: RecipientList.java component/bean/MethodInfo.java

Author: davsclaus
Date: Thu May 13 07:21:23 2010
New Revision: 943830

URL: http://svn.apache.org/viewvc?rev=943830&view=rev
Log:
CAMEL-2710: Added new option on @RecipientList annotation.

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/RecipientList.java
    camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/RecipientList.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/RecipientList.java?rev=943830&r1=943829&r2=943830&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/RecipientList.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/RecipientList.java Thu May 13 07:21:23 2010
@@ -47,6 +47,7 @@ public @interface RecipientList {
     String delimiter() default ",";
     boolean parallelProcessing() default false;
     boolean stopOnException() default false;
+    boolean ignoreInvalidEndpoints() default false;
     String strategyRef() default "";
     String executorServiceRef() default "";
 }
\ No newline at end of file

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java?rev=943830&r1=943829&r2=943830&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/bean/MethodInfo.java Thu May 13 07:21:23 2010
@@ -84,6 +84,7 @@ public class MethodInfo {
 
             recipientList = new RecipientList(camelContext, annotation.delimiter());
             recipientList.setStopOnException(annotation.stopOnException());
+            recipientList.setIgnoreInvalidEndpoints(annotation.ignoreInvalidEndpoints());
             recipientList.setParallelProcessing(annotation.parallelProcessing());
 
             if (ObjectHelper.isNotEmpty(annotation.executorServiceRef())) {