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())) {
