public class org.apache.camel.model.MulticastDefinition extends org.apache.camel.model.OutputDefinition implements org.apache.camel.model.ExecutorServiceAwareDefinition
{
private java.lang.Boolean parallelProcessing;
private java.lang.String strategyRef;
private java.lang.String strategyMethodName;
private java.lang.Boolean strategyMethodAllowNull;
private java.util.concurrent.ExecutorService executorService;
private java.lang.String executorServiceRef;
private java.lang.Boolean streaming;
private java.lang.Boolean stopOnException;
private java.lang.Long timeout;
private org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy;
private java.lang.String onPrepareRef;
private org.apache.camel.Processor onPrepare;
private java.lang.Boolean shareUnitOfWork;
private java.lang.Boolean parallelAggregate;
private java.lang.Boolean stopOnAggregateException;
public void <init>()
{
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
specialinvoke v.<org.apache.camel.model.OutputDefinition: void <init>()>();
return;
}
public java.lang.String toString()
{
org.apache.camel.model.MulticastDefinition v;
java.util.List v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: java.util.List getOutputs()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.List)>(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[])>("Multicast[\u]");
return v;
}
public java.lang.String getShortName()
{
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
return "multicast";
}
public java.lang.String getLabel()
{
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
return "multicast";
}
public org.apache.camel.Processor createProcessor(org.apache.camel.spi.RouteContext) throws java.lang.Exception
{
org.apache.camel.Processor v;
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.spi.RouteContext v;
boolean v;
java.util.ArrayList v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.Processor createChildProcessor(org.apache.camel.spi.RouteContext,boolean)>(v, 1);
v = v instanceof org.apache.camel.processor.MulticastProcessor;
if v != 0 goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(1);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.Processor createCompositeProcessor(org.apache.camel.spi.RouteContext,java.util.List)>(v, v);
label:
return v;
}
public org.apache.camel.builder.AggregationStrategyClause aggregationStrategy()
{
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.builder.AggregationStrategyClause v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = new org.apache.camel.builder.AggregationStrategyClause;
specialinvoke v.<org.apache.camel.builder.AggregationStrategyClause: void <init>(java.lang.Object)>(v);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.model.MulticastDefinition setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition aggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)
{
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.processor.aggregate.AggregationStrategy;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.model.MulticastDefinition setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition aggregationStrategyRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStrategyRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition aggregationStrategyMethodName(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStrategyMethodName(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition aggregationStrategyMethodAllowNull()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStrategyMethodAllowNull(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition parallelProcessing()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setParallelProcessing(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition parallelProcessing(boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
boolean v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setParallelProcessing(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition parallelAggregate()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setParallelAggregate(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition stopOnAggregateException()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStopOnAggregateException(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition streaming()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStreaming(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition stopOnException()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setStopOnException(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition executorService(java.util.concurrent.ExecutorService)
{
org.apache.camel.model.MulticastDefinition v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.util.concurrent.ExecutorService;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setExecutorService(java.util.concurrent.ExecutorService)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition executorServiceRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setExecutorServiceRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.builder.ProcessClause onPrepare()
{
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.builder.ProcessClause v;
v := @this: org.apache.camel.model.MulticastDefinition;
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.MulticastDefinition: void setOnPrepare(org.apache.camel.Processor)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition onPrepare(org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.Processor;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setOnPrepare(org.apache.camel.Processor)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition onPrepareRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setOnPrepareRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition timeout(long)
{
org.apache.camel.model.MulticastDefinition v;
long v;
java.lang.Long v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setTimeout(java.lang.Long)>(v);
return v;
}
public org.apache.camel.model.MulticastDefinition shareUnitOfWork()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.MulticastDefinition: void setShareUnitOfWork(java.lang.Boolean)>(v);
return v;
}
protected org.apache.camel.Processor createCompositeProcessor(org.apache.camel.spi.RouteContext, java.util.List) throws java.lang.Exception
{
org.apache.camel.processor.MulticastProcessor v;
byte v;
java.lang.Long v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v;
org.apache.camel.spi.RouteContext v;
long v, v;
org.apache.camel.Processor v;
org.apache.camel.model.MulticastDefinition v;
java.lang.Boolean v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
java.util.concurrent.ExecutorService v;
org.apache.camel.CamelContext v, v;
java.lang.IllegalArgumentException v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
java.lang.Object v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v := @parameter: java.util.List;
v = specialinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.processor.aggregate.AggregationStrategy createAggregationStrategy(org.apache.camel.spi.RouteContext)>(v);
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean getParallelProcessing()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getShareUnitOfWork()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getStreaming()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getStopOnException()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getParallelAggregate()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getStopOnAggregateException()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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 = 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, "Multicast", v, v);
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: java.lang.Long getTimeout()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: java.lang.Long getTimeout()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
goto label;
label:
v = 0L;
label:
v = v;
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 = v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: 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.MulticastDefinition: org.apache.camel.Processor onPrepare> = v;
label:
v = new org.apache.camel.processor.MulticastProcessor;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.Processor onPrepare>;
specialinvoke v.<org.apache.camel.processor.MulticastProcessor: void <init>(org.apache.camel.CamelContext,java.util.Collection,org.apache.camel.processor.aggregate.AggregationStrategy,boolean,java.util.concurrent.ExecutorService,boolean,boolean,boolean,long,org.apache.camel.Processor,boolean,boolean,boolean)>(v, v, v, v, v, v, v, v, v, 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.MulticastDefinition 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.MulticastDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.processor.aggregate.AggregationStrategy getAggregationStrategy()>();
if v != null goto label;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.String strategyRef>;
if v == null goto label;
v = v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean getStrategyMethodAllowNull()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.MulticastDefinition: 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.MulticastDefinition: 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.MulticastDefinition: 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.MulticastDefinition: java.lang.Boolean shareUnitOfWork>;
if v == null goto label;
v = v.<org.apache.camel.model.MulticastDefinition: 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.processor.aggregate.AggregationStrategy getAggregationStrategy()
{
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy>;
return v;
}
public org.apache.camel.model.MulticastDefinition setAggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy)
{
org.apache.camel.model.MulticastDefinition v;
org.apache.camel.processor.aggregate.AggregationStrategy v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.processor.aggregate.AggregationStrategy;
v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy> = v;
return v;
}
public java.lang.Boolean getParallelProcessing()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean parallelProcessing>;
return v;
}
public void setParallelProcessing(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean parallelProcessing> = v;
return;
}
public java.lang.Boolean getStreaming()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean streaming>;
return v;
}
public void setStreaming(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean streaming> = v;
return;
}
public java.lang.Boolean getStopOnException()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean stopOnException>;
return v;
}
public void setStopOnException(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean stopOnException> = v;
return;
}
public java.util.concurrent.ExecutorService getExecutorService()
{
org.apache.camel.model.MulticastDefinition v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.util.concurrent.ExecutorService executorService>;
return v;
}
public void setExecutorService(java.util.concurrent.ExecutorService)
{
org.apache.camel.model.MulticastDefinition v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.util.concurrent.ExecutorService;
v.<org.apache.camel.model.MulticastDefinition: java.util.concurrent.ExecutorService executorService> = v;
return;
}
public java.lang.String getStrategyRef()
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.String strategyRef>;
return v;
}
public void setStrategyRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.MulticastDefinition: java.lang.String strategyRef> = v;
return;
}
public java.lang.String getStrategyMethodName()
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.String strategyMethodName>;
return v;
}
public void setStrategyMethodName(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.MulticastDefinition: java.lang.String strategyMethodName> = v;
return;
}
public java.lang.Boolean getStrategyMethodAllowNull()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean strategyMethodAllowNull>;
return v;
}
public void setStrategyMethodAllowNull(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean strategyMethodAllowNull> = v;
return;
}
public java.lang.String getExecutorServiceRef()
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.String executorServiceRef>;
return v;
}
public void setExecutorServiceRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.MulticastDefinition: java.lang.String executorServiceRef> = v;
return;
}
public java.lang.Long getTimeout()
{
org.apache.camel.model.MulticastDefinition v;
java.lang.Long v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Long timeout>;
return v;
}
public void setTimeout(java.lang.Long)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.Long v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Long;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Long timeout> = v;
return;
}
public java.lang.String getOnPrepareRef()
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.String onPrepareRef>;
return v;
}
public void setOnPrepareRef(java.lang.String)
{
org.apache.camel.model.MulticastDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.MulticastDefinition: java.lang.String onPrepareRef> = v;
return;
}
public org.apache.camel.Processor getOnPrepare()
{
org.apache.camel.Processor v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.Processor onPrepare>;
return v;
}
public void setOnPrepare(org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: org.apache.camel.Processor;
v.<org.apache.camel.model.MulticastDefinition: org.apache.camel.Processor onPrepare> = v;
return;
}
public java.lang.Boolean getShareUnitOfWork()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean shareUnitOfWork>;
return v;
}
public void setShareUnitOfWork(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean shareUnitOfWork> = v;
return;
}
public java.lang.Boolean getParallelAggregate()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean parallelAggregate>;
return v;
}
public void setParallelAggregate(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean parallelAggregate> = v;
return;
}
public java.lang.Boolean getStopOnAggregateException()
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v = v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean stopOnAggregateException>;
return v;
}
public void setStopOnAggregateException(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.MulticastDefinition v;
v := @this: org.apache.camel.model.MulticastDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.MulticastDefinition: java.lang.Boolean stopOnAggregateException> = v;
return;
}
}