public class org.apache.camel.model.ResequenceDefinition extends org.apache.camel.model.ProcessorDefinition
{
private org.apache.camel.model.config.ResequencerConfig resequencerConfig;
private org.apache.camel.model.config.BatchResequencerConfig batchConfig;
private org.apache.camel.model.config.StreamResequencerConfig streamConfig;
private org.apache.camel.model.language.ExpressionDefinition expression;
private java.util.List outputs;
public void <init>()
{
org.apache.camel.model.ResequenceDefinition v;
java.util.ArrayList v;
v := @this: org.apache.camel.model.ResequenceDefinition;
specialinvoke v.<org.apache.camel.model.ProcessorDefinition: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.camel.model.ResequenceDefinition: java.util.List outputs> = v;
return;
}
public void <init>(org.apache.camel.Expression)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.Expression v;
java.util.ArrayList v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.Expression;
specialinvoke v.<org.apache.camel.model.ProcessorDefinition: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.camel.model.ResequenceDefinition: java.util.List outputs> = v;
if v == null goto label;
v = staticinvoke <org.apache.camel.model.ExpressionNodeHelper: org.apache.camel.model.language.ExpressionDefinition toExpressionDefinition(org.apache.camel.Expression)>(v);
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: void setExpression(org.apache.camel.model.language.ExpressionDefinition)>(v);
label:
return;
}
public java.util.List getOutputs()
{
org.apache.camel.model.ResequenceDefinition v;
java.util.List v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: java.util.List outputs>;
return v;
}
public void setOutputs(java.util.List)
{
org.apache.camel.model.ResequenceDefinition v;
java.util.List v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: java.util.List;
v.<org.apache.camel.model.ResequenceDefinition: java.util.List outputs> = v;
return;
}
public boolean isOutputSupported()
{
org.apache.camel.model.ResequenceDefinition v;
v := @this: org.apache.camel.model.ResequenceDefinition;
return 1;
}
public org.apache.camel.model.ResequenceDefinition stream()
{
org.apache.camel.model.ResequenceDefinition v, v;
org.apache.camel.model.config.StreamResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = staticinvoke <org.apache.camel.model.config.StreamResequencerConfig: org.apache.camel.model.config.StreamResequencerConfig getDefault()>();
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition stream(org.apache.camel.model.config.StreamResequencerConfig)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition batch()
{
org.apache.camel.model.ResequenceDefinition v, v;
org.apache.camel.model.config.BatchResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = staticinvoke <org.apache.camel.model.config.BatchResequencerConfig: org.apache.camel.model.config.BatchResequencerConfig getDefault()>();
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch(org.apache.camel.model.config.BatchResequencerConfig)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition stream(org.apache.camel.model.config.StreamResequencerConfig)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.config.StreamResequencerConfig;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig> = v;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig> = null;
return v;
}
public org.apache.camel.model.ResequenceDefinition batch(org.apache.camel.model.config.BatchResequencerConfig)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.BatchResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.config.BatchResequencerConfig;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig> = v;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig> = null;
return v;
}
public org.apache.camel.model.ResequenceDefinition timeout(long)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
long v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: long;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setTimeout(long)>(v);
goto label;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: void setBatchTimeout(long)>(v);
label:
return v;
}
public org.apache.camel.model.ResequenceDefinition deliveryAttemptInterval(long)
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
java.lang.Long v;
long v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: long;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("deliveryAttemptInterval() only supported for stream resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setDeliveryAttemptInterval(java.lang.Long)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition rejectOld()
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("rejectOld() only supported for stream resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setRejectOld(boolean)>(1);
return v;
}
public org.apache.camel.model.ResequenceDefinition size(int)
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
int v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: int;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("size() only supported for batch resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: void setBatchSize(int)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition capacity(int)
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
int v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: int;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("capacity() only supported for stream resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setCapacity(int)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition allowDuplicates()
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
java.lang.Boolean v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("allowDuplicates() only supported for batch resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: void setAllowDuplicates(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition reverse()
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
java.lang.Boolean v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("reverse() only supported for batch resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: void setReverse(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.ResequenceDefinition ignoreInvalidExchanges()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
java.lang.Boolean v, v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setIgnoreInvalidExchanges(java.lang.Boolean)>(v);
goto label;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: void setIgnoreInvalidExchanges(java.lang.Boolean)>(v);
label:
return v;
}
public org.apache.camel.model.ResequenceDefinition comparator(org.apache.camel.processor.resequencer.ExpressionResultComparator)
{
java.lang.IllegalStateException v;
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
org.apache.camel.processor.resequencer.ExpressionResultComparator v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.processor.resequencer.ExpressionResultComparator;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("comparator() only supported for stream resequencer");
throw v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: void setComparator(org.apache.camel.processor.resequencer.ExpressionResultComparator)>(v);
return v;
}
public java.lang.String toString()
{
org.apache.camel.model.ResequenceDefinition v;
java.util.List v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: java.util.List getOutputs()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.model.language.ExpressionDefinition,java.util.List)>(v, 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[])>("Resequencer[\u -> \u]");
return v;
}
public java.lang.String getShortName()
{
org.apache.camel.model.ResequenceDefinition v;
v := @this: org.apache.camel.model.ResequenceDefinition;
return "resequence";
}
public java.lang.String getLabel()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.language.ExpressionDefinition v, v;
java.lang.String v, v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getLabel()>();
goto label;
label:
v = "";
label:
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[])>("resequencer[\u]");
return v;
}
public org.apache.camel.model.config.ResequencerConfig getResequencerConfig()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.ResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
return v;
}
public void setResequencerConfig(org.apache.camel.model.config.ResequencerConfig)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.ResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.config.ResequencerConfig;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig> = v;
return;
}
public org.apache.camel.model.config.BatchResequencerConfig getBatchConfig()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
org.apache.camel.model.config.ResequencerConfig v, v, v;
boolean v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
v = v instanceof org.apache.camel.model.config.BatchResequencerConfig;
if v == 0 goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
return v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
return v;
}
public org.apache.camel.model.config.StreamResequencerConfig getStreamConfig()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
org.apache.camel.model.config.ResequencerConfig v, v, v;
boolean v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v != null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
v = v instanceof org.apache.camel.model.config.StreamResequencerConfig;
if v == 0 goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
return v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
return v;
}
public void setBatchConfig(org.apache.camel.model.config.BatchResequencerConfig)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.BatchResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.config.BatchResequencerConfig;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig> = v;
return;
}
public void setStreamConfig(org.apache.camel.model.config.StreamResequencerConfig)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.config.StreamResequencerConfig v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.config.StreamResequencerConfig;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig> = v;
return;
}
public org.apache.camel.model.language.ExpressionDefinition getExpression()
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.language.ExpressionDefinition v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.language.ExpressionDefinition expression>;
return v;
}
public void setExpression(org.apache.camel.model.language.ExpressionDefinition)
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.model.language.ExpressionDefinition v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.model.language.ExpressionDefinition;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.language.ExpressionDefinition expression> = v;
return;
}
public org.apache.camel.Processor createProcessor(org.apache.camel.spi.RouteContext) throws java.lang.Exception
{
org.apache.camel.model.ResequenceDefinition v;
org.apache.camel.processor.Resequencer v;
org.apache.camel.processor.StreamResequencer v;
org.apache.camel.model.config.StreamResequencerConfig v, v;
org.apache.camel.model.config.BatchResequencerConfig v, v;
org.apache.camel.model.config.ResequencerConfig v, v, v, v;
org.apache.camel.spi.RouteContext v;
boolean v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
v = v instanceof org.apache.camel.model.config.StreamResequencerConfig;
if v == 0 goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig> = v;
goto label;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.ResequencerConfig resequencerConfig>;
v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig> = v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
if v == null goto label;
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.StreamResequencerConfig streamConfig>;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.processor.StreamResequencer createStreamResequencer(org.apache.camel.spi.RouteContext,org.apache.camel.model.config.StreamResequencerConfig)>(v, v);
return v;
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
if v != null goto label;
virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.ResequenceDefinition batch()>();
label:
v = v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.model.config.BatchResequencerConfig batchConfig>;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.processor.Resequencer createBatchResequencer(org.apache.camel.spi.RouteContext,org.apache.camel.model.config.BatchResequencerConfig)>(v, v);
return v;
}
protected org.apache.camel.processor.Resequencer createBatchResequencer(org.apache.camel.spi.RouteContext, org.apache.camel.model.config.BatchResequencerConfig) throws java.lang.Exception
{
org.apache.camel.model.ResequenceDefinition v;
long v;
org.apache.camel.Expression v;
org.apache.camel.processor.CamelInternalProcessor v;
org.apache.camel.processor.Resequencer v;
org.apache.camel.Processor v;
org.apache.camel.model.config.BatchResequencerConfig v;
int v;
java.lang.Boolean v, v, v, v, v, v;
boolean v, v, v, v, v, v;
org.apache.camel.CamelContext v;
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice v;
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.spi.RouteContext v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v := @parameter: org.apache.camel.model.config.BatchResequencerConfig;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.Processor createChildProcessor(org.apache.camel.spi.RouteContext,boolean)>(v, 1);
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: 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 = new org.apache.camel.processor.CamelInternalProcessor;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void <init>(org.apache.camel.Processor)>(v);
v = new org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice: void <init>(org.apache.camel.spi.RouteContext)>(v);
virtualinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void addAdvice(org.apache.camel.processor.CamelInternalProcessorAdvice)>(v);
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "config", v);
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "expression", v);
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: java.lang.Boolean getReverse()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: java.lang.Boolean getReverse()>();
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.config.BatchResequencerConfig: java.lang.Boolean getAllowDuplicates()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: java.lang.Boolean getAllowDuplicates()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = new org.apache.camel.processor.Resequencer;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.processor.Resequencer: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.Expression,boolean,boolean)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: int getBatchSize()>();
virtualinvoke v.<org.apache.camel.processor.Resequencer: void setBatchSize(int)>(v);
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: long getBatchTimeout()>();
virtualinvoke v.<org.apache.camel.processor.Resequencer: void setBatchTimeout(long)>(v);
virtualinvoke v.<org.apache.camel.processor.Resequencer: void setReverse(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.Resequencer: void setAllowDuplicates(boolean)>(v);
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: java.lang.Boolean getIgnoreInvalidExchanges()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.config.BatchResequencerConfig: java.lang.Boolean getIgnoreInvalidExchanges()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.camel.processor.Resequencer: void setIgnoreInvalidExchanges(boolean)>(v);
label:
return v;
}
protected org.apache.camel.processor.StreamResequencer createStreamResequencer(org.apache.camel.spi.RouteContext, org.apache.camel.model.config.StreamResequencerConfig) throws java.lang.Exception
{
org.apache.camel.model.ResequenceDefinition v;
long v, v;
org.apache.camel.Expression v;
org.apache.camel.processor.CamelInternalProcessor v;
org.apache.camel.Processor v;
java.lang.Long v, v;
int v;
java.lang.Boolean v, v, v;
java.lang.String v, v;
boolean v;
org.apache.camel.CamelContext v, v;
org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice v;
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.processor.StreamResequencer v;
org.apache.camel.model.config.StreamResequencerConfig v;
java.lang.Object v;
org.apache.camel.spi.RouteContext v;
v := @this: org.apache.camel.model.ResequenceDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v := @parameter: org.apache.camel.model.config.StreamResequencerConfig;
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: org.apache.camel.Processor createChildProcessor(org.apache.camel.spi.RouteContext,boolean)>(v, 1);
v = virtualinvoke v.<org.apache.camel.model.ResequenceDefinition: 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 = new org.apache.camel.processor.CamelInternalProcessor;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void <init>(org.apache.camel.Processor)>(v);
v = new org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice;
specialinvoke v.<org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice: void <init>(org.apache.camel.spi.RouteContext)>(v);
virtualinvoke v.<org.apache.camel.processor.CamelInternalProcessor: void addAdvice(org.apache.camel.processor.CamelInternalProcessorAdvice)>(v);
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "config", v);
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "expression", v);
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.String getComparatorRef()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.String getComparatorRef()>();
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/resequencer/ExpressionResultComparator;");
goto label;
label:
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: org.apache.camel.processor.resequencer.ExpressionResultComparator getComparator()>();
label:
interfaceinvoke v.<org.apache.camel.processor.resequencer.ExpressionResultComparator: void setExpression(org.apache.camel.Expression)>(v);
v = new org.apache.camel.processor.StreamResequencer;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.processor.StreamResequencer: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.processor.resequencer.SequenceElementComparator,org.apache.camel.Expression)>(v, v, v, v);
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: long getTimeout()>();
virtualinvoke v.<org.apache.camel.processor.StreamResequencer: void setTimeout(long)>(v);
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.Long getDeliveryAttemptInterval()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.Long getDeliveryAttemptInterval()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.camel.processor.StreamResequencer: void setDeliveryAttemptInterval(long)>(v);
label:
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: int getCapacity()>();
virtualinvoke v.<org.apache.camel.processor.StreamResequencer: void setCapacity(int)>(v);
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.Boolean getRejectOld()>();
virtualinvoke v.<org.apache.camel.processor.StreamResequencer: void setRejectOld(java.lang.Boolean)>(v);
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.Boolean getIgnoreInvalidExchanges()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.config.StreamResequencerConfig: java.lang.Boolean getIgnoreInvalidExchanges()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<org.apache.camel.processor.StreamResequencer: void setIgnoreInvalidExchanges(boolean)>(v);
label:
return v;
}
}