public class org.apache.camel.model.RecipientListDefinition extends org.apache.camel.model.NoOutputExpressionNode implements org.apache.camel.model.ExecutorServiceAwareDefinition
{
private org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy;
private java.util.concurrent.ExecutorService executorService;
private java.lang.String delimiter;
private java.lang.Boolean parallelProcessing;
private java.lang.String strategyRef;
private java.lang.String strategyMethodName;
private java.lang.Boolean strategyMethodAllowNull;
private java.lang.String executorServiceRef;
private java.lang.Boolean stopOnException;
private java.lang.Boolean ignoreInvalidEndpoints;
private java.lang.Boolean streaming;
private java.lang.Long timeout;
private java.lang.String onPrepareRef;
private org.apache.camel.Processor onPrepare;
private java.lang.Boolean shareUnitOfWork;
private java.lang.Integer cacheSize;
private java.lang.Boolean parallelAggregate;
private java.lang.Boolean stopOnAggregateException;
public void <init>()
{
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: void <init>()>();
return;
}
public void <init>(org.apache.camel.model.language.ExpressionDefinition)
{
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.model.language.ExpressionDefinition;
specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: void <init>(org.apache.camel.model.language.ExpressionDefinition)>(v);
return;
}
public void <init>(org.apache.camel.Expression)
{
org.apache.camel.Expression v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.Expression;
specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: void <init>(org.apache.camel.Expression)>(v);
return;
}
public java.lang.String toString()
{
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.model.language.ExpressionDefinition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("RecipientList[\u]");
return v;
}
public java.lang.String getShortName()
{
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
return "recipientList";
}
public java.lang.String getLabel()
{
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.model.language.ExpressionDefinition)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("recipientList[\u]");
return v;
}
public org.apache.camel.Processor createProcessor(org.apache.camel.spi.RouteContext) throws java.lang.Exception
{
java.lang.Integer v, v;
byte v;
java.lang.Long v, v, v, v;
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.spi.RouteContext v;
org.apache.camel.processor.RecipientList v, v, v;
long v, v;
java.util.ArrayList v;
org.apache.camel.processor.EvaluateExpressionProcessor v;
java.lang.String v, v, v, v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.camel.model.RecipientListDefinition$1 v;
org.apache.camel.model.RecipientListDefinition v;
org.apache.camel.Expression v;
org.apache.camel.Processor v, v, v;
int v;
java.lang.Boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.concurrent.ExecutorService v;
org.apache.camel.CamelContext v, v, v, v;
java.lang.IllegalArgumentException v;
java.lang.Object v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: org.apache.camel.Expression createExpression(org.apache.camel.spi.RouteContext)>(v);
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getParallelProcessing()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getParallelProcessing()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStreaming()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStreaming()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getParallelAggregate()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getParallelAggregate()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getShareUnitOfWork()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getShareUnitOfWork()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStopOnException()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStopOnException()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getIgnoreInvalidEndpoints()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getIgnoreInvalidEndpoints()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStopOnAggregateException()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStopOnAggregateException()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String delimiter>;
if v == null goto label;
v = new org.apache.camel.processor.RecipientList;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String delimiter>;
specialinvoke v.<org.apache.camel.processor.RecipientList: void <init>(org.apache.camel.CamelContext,org.apache.camel.Expression,java.lang.String)>(v, v, v);
v = v;
goto label;
label:
v = new org.apache.camel.processor.RecipientList;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.processor.RecipientList: void <init>(org.apache.camel.CamelContext,org.apache.camel.Expression)>(v, v);
v = v;
label:
v = specialinvoke v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.processor.aggregate.AggregationStrategy createAggregationStrategy(org.apache.camel.spi.RouteContext)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setParallelProcessing(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setParallelAggregate(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setStreaming(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setShareUnitOfWork(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setStopOnException(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setIgnoreInvalidEndpoints(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setStopOnAggregateException(boolean)>(v);
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Integer getCacheSize()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Integer getCacheSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setCacheSize(int)>(v);
label:
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String onPrepareRef>;
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String onPrepareRef>;
v = staticinvoke <org.apache.camel.util.CamelContextHelper: java.lang.Object mandatoryLookup(org.apache.camel.CamelContext,java.lang.String,java.lang.Class)>(v, v, class "Lorg/apache/camel/Processor;");
v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.Processor onPrepare> = v;
label:
v = v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.Processor onPrepare>;
if v == null goto label;
v = v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.Processor onPrepare>;
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setOnPrepare(org.apache.camel.Processor)>(v);
label:
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long getTimeout()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long getTimeout()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setTimeout(long)>(v);
label:
v = staticinvoke <org.apache.camel.model.ProcessorDefinitionHelper: boolean willCreateNewThreadPool(org.apache.camel.spi.RouteContext,org.apache.camel.model.ExecutorServiceAwareDefinition,boolean)>(v, v, v);
v = staticinvoke <org.apache.camel.model.ProcessorDefinitionHelper: java.util.concurrent.ExecutorService getConfiguredExecutorService(org.apache.camel.spi.RouteContext,java.lang.String,org.apache.camel.model.ExecutorServiceAwareDefinition,boolean)>(v, "RecipientList", v, v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setExecutorService(java.util.concurrent.ExecutorService)>(v);
virtualinvoke v.<org.apache.camel.processor.RecipientList: void setShutdownExecutorService(boolean)>(v);
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long getTimeout()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long getTimeout()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
goto label;
label:
v = 0L;
label:
v = v cmp 0L;
if v <= 0 goto label;
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Timeout is used but ParallelProcessing has not been enabled.");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(2);
v = new org.apache.camel.processor.EvaluateExpressionProcessor;
specialinvoke v.<org.apache.camel.processor.EvaluateExpressionProcessor: void <init>(org.apache.camel.Expression)>(v);
v = specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: org.apache.camel.Processor wrapInErrorHandler(org.apache.camel.spi.RouteContext,org.apache.camel.Processor)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.camel.model.RecipientListDefinition$1;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.model.RecipientListDefinition$1: void <init>(org.apache.camel.model.RecipientListDefinition,org.apache.camel.CamelContext,java.util.Collection,org.apache.camel.Expression)>(v, v, v, v);
return v;
}
private org.apache.camel.processor.aggregate.AggregationStrategy createAggregationStrategy(org.apache.camel.spi.RouteContext)
{
org.apache.camel.processor.aggregate.AggregationStrategyBeanAdapter v;
org.apache.camel.model.RecipientListDefinition v;
org.apache.camel.processor.aggregate.ShareUnitOfWorkAggregationStrategy v;
java.lang.Boolean v, v, v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v, v;
org.apache.camel.CamelContext v;
org.apache.camel.processor.aggregate.UseLatestAggregationStrategy v;
java.lang.IllegalArgumentException v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
java.lang.Object v;
org.apache.camel.spi.RouteContext v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.processor.aggregate.AggregationStrategy getAggregationStrategy()>();
if v != null goto label;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyRef>;
if v == null goto label;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyRef>;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.lang.Object lookup(java.lang.String,java.lang.Class)>(v, class "Ljava/lang/Object;");
v = v instanceof org.apache.camel.processor.aggregate.AggregationStrategy;
if v != 0 goto label;
if v == null goto label;
v = new org.apache.camel.processor.aggregate.AggregationStrategyBeanAdapter;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.String getStrategyMethodName()>();
specialinvoke v.<org.apache.camel.processor.aggregate.AggregationStrategyBeanAdapter: void <init>(java.lang.Object,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStrategyMethodAllowNull()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStrategyMethodAllowNull()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.camel.processor.aggregate.AggregationStrategyBeanAdapter: void setAllowNullNewExchange(boolean)>(v);
v = virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean getStrategyMethodAllowNull()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.camel.processor.aggregate.AggregationStrategyBeanAdapter: void setAllowNullOldExchange(boolean)>(v);
label:
v = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyRef>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot find AggregationStrategy in Registry with name: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != null goto label;
v = new org.apache.camel.processor.aggregate.UseLatestAggregationStrategy;
specialinvoke v.<org.apache.camel.processor.aggregate.UseLatestAggregationStrategy: void <init>()>();
v = v;
label:
v = v instanceof org.apache.camel.CamelContextAware;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
interfaceinvoke v.<org.apache.camel.CamelContextAware: void setCamelContext(org.apache.camel.CamelContext)>(v);
label:
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean shareUnitOfWork>;
if v == null goto label;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean shareUnitOfWork>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = new org.apache.camel.processor.aggregate.ShareUnitOfWorkAggregationStrategy;
specialinvoke v.<org.apache.camel.processor.aggregate.ShareUnitOfWorkAggregationStrategy: void <init>(org.apache.camel.processor.aggregate.AggregationStrategy)>(v);
v = v;
label:
return v;
}
public org.apache.camel.model.ProcessorDefinition end()
{
org.apache.camel.model.ProcessorDefinition v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: org.apache.camel.model.ProcessorDefinition end()>();
return v;
}
public org.apache.camel.model.RecipientListDefinition delimiter(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setDelimiter(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition aggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)
{
org.apache.camel.processor.aggregate.AggregationStrategy v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.processor.aggregate.AggregationStrategy;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition aggregationStrategyRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStrategyRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition aggregationStrategyMethodName(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStrategyMethodName(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition aggregationStrategyMethodAllowNull()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStrategyMethodAllowNull(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition ignoreInvalidEndpoints()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setIgnoreInvalidEndpoints(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition parallelProcessing()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setParallelProcessing(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition parallelProcessing(boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setParallelProcessing(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition parallelAggregate()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setParallelAggregate(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition stopOnAggregateException()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStopOnAggregateException(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition streaming()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStreaming(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition stopOnException()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setStopOnException(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition executorService(java.util.concurrent.ExecutorService)
{
java.util.concurrent.ExecutorService v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.util.concurrent.ExecutorService;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setExecutorService(java.util.concurrent.ExecutorService)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition executorServiceRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setExecutorServiceRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition onPrepare(org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.Processor;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setOnPrepare(org.apache.camel.Processor)>(v);
return v;
}
public org.apache.camel.builder.ProcessClause onPrepare()
{
org.apache.camel.builder.ProcessClause v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = new org.apache.camel.builder.ProcessClause;
specialinvoke v.<org.apache.camel.builder.ProcessClause: void <init>(java.lang.Object)>(v);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setOnPrepare(org.apache.camel.Processor)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition onPrepareRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setOnPrepareRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition timeout(long)
{
long v;
java.lang.Long v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setTimeout(java.lang.Long)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition shareUnitOfWork()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setShareUnitOfWork(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.RecipientListDefinition cacheSize(int)
{
int v;
java.lang.Integer v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: int;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.camel.model.RecipientListDefinition: void setCacheSize(java.lang.Integer)>(v);
return v;
}
public void setExpression(org.apache.camel.model.language.ExpressionDefinition)
{
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.model.language.ExpressionDefinition;
specialinvoke v.<org.apache.camel.model.NoOutputExpressionNode: void setExpression(org.apache.camel.model.language.ExpressionDefinition)>(v);
return;
}
public java.lang.String getDelimiter()
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String delimiter>;
return v;
}
public void setDelimiter(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.String delimiter> = v;
return;
}
public java.lang.Boolean getParallelProcessing()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean parallelProcessing>;
return v;
}
public void setParallelProcessing(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean parallelProcessing> = v;
return;
}
public java.lang.String getStrategyRef()
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyRef>;
return v;
}
public void setStrategyRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyRef> = v;
return;
}
public java.lang.String getStrategyMethodName()
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyMethodName>;
return v;
}
public void setStrategyMethodName(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.String strategyMethodName> = v;
return;
}
public java.lang.Boolean getStrategyMethodAllowNull()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean strategyMethodAllowNull>;
return v;
}
public void setStrategyMethodAllowNull(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean strategyMethodAllowNull> = v;
return;
}
public java.lang.String getExecutorServiceRef()
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String executorServiceRef>;
return v;
}
public void setExecutorServiceRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.String executorServiceRef> = v;
return;
}
public java.lang.Boolean getIgnoreInvalidEndpoints()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean ignoreInvalidEndpoints>;
return v;
}
public void setIgnoreInvalidEndpoints(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean ignoreInvalidEndpoints> = v;
return;
}
public java.lang.Boolean getStopOnException()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean stopOnException>;
return v;
}
public void setStopOnException(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean stopOnException> = v;
return;
}
public org.apache.camel.processor.aggregate.AggregationStrategy getAggregationStrategy()
{
org.apache.camel.processor.aggregate.AggregationStrategy v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy>;
return v;
}
public void setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)
{
org.apache.camel.processor.aggregate.AggregationStrategy v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.processor.aggregate.AggregationStrategy;
v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy> = v;
return;
}
public java.util.concurrent.ExecutorService getExecutorService()
{
java.util.concurrent.ExecutorService v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.util.concurrent.ExecutorService executorService>;
return v;
}
public void setExecutorService(java.util.concurrent.ExecutorService)
{
java.util.concurrent.ExecutorService v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.util.concurrent.ExecutorService;
v.<org.apache.camel.model.RecipientListDefinition: java.util.concurrent.ExecutorService executorService> = v;
return;
}
public java.lang.Boolean getStreaming()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean streaming>;
return v;
}
public void setStreaming(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean streaming> = v;
return;
}
public java.lang.Long getTimeout()
{
java.lang.Long v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long timeout>;
return v;
}
public void setTimeout(java.lang.Long)
{
java.lang.Long v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Long;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Long timeout> = v;
return;
}
public java.lang.String getOnPrepareRef()
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.String onPrepareRef>;
return v;
}
public void setOnPrepareRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.String onPrepareRef> = v;
return;
}
public org.apache.camel.Processor getOnPrepare()
{
org.apache.camel.Processor v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.Processor onPrepare>;
return v;
}
public void setOnPrepare(org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: org.apache.camel.Processor;
v.<org.apache.camel.model.RecipientListDefinition: org.apache.camel.Processor onPrepare> = v;
return;
}
public java.lang.Boolean getShareUnitOfWork()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean shareUnitOfWork>;
return v;
}
public void setShareUnitOfWork(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean shareUnitOfWork> = v;
return;
}
public java.lang.Integer getCacheSize()
{
java.lang.Integer v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Integer cacheSize>;
return v;
}
public void setCacheSize(java.lang.Integer)
{
java.lang.Integer v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Integer;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Integer cacheSize> = v;
return;
}
public java.lang.Boolean getParallelAggregate()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean parallelAggregate>;
return v;
}
public void setParallelAggregate(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean parallelAggregate> = v;
return;
}
public java.lang.Boolean getStopOnAggregateException()
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v = v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean stopOnAggregateException>;
return v;
}
public void setStopOnAggregateException(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.RecipientListDefinition v;
v := @this: org.apache.camel.model.RecipientListDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.RecipientListDefinition: java.lang.Boolean stopOnAggregateException> = v;
return;
}
}