public class org.apache.camel.model.IdempotentConsumerDefinition extends org.apache.camel.model.ExpressionNode
{
private java.lang.String messageIdRepositoryRef;
private java.lang.Boolean eager;
private java.lang.Boolean completionEager;
private java.lang.Boolean skipDuplicate;
private java.lang.Boolean removeOnFailure;
private org.apache.camel.spi.IdempotentRepository idempotentRepository;
public void <init>()
{
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
specialinvoke v.<org.apache.camel.model.ExpressionNode: void <init>()>();
return;
}
public void <init>(org.apache.camel.Expression, org.apache.camel.spi.IdempotentRepository)
{
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.Expression v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.Expression;
v := @parameter: org.apache.camel.spi.IdempotentRepository;
specialinvoke v.<org.apache.camel.model.ExpressionNode: void <init>(org.apache.camel.Expression)>(v);
v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository idempotentRepository> = v;
return;
}
public java.lang.String toString()
{
java.util.List v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.model.language.ExpressionDefinition getExpression()>();
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: 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[])>("IdempotentConsumer[\u -> \u]");
return v;
}
public java.lang.String getShortName()
{
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
return "idempotentConsumer";
}
public java.lang.String getLabel()
{
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: 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[])>("idempotentConsumer[\u]");
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition messageIdRepositoryRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setMessageIdRepositoryRef(java.lang.String)>(v);
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition messageIdRepository(org.apache.camel.spi.IdempotentRepository)
{
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.spi.IdempotentRepository;
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setMessageIdRepository(org.apache.camel.spi.IdempotentRepository)>(v);
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition eager(boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setEager(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition completionEager(boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setCompletionEager(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition removeOnFailure(boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setRemoveOnFailure(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.model.IdempotentConsumerDefinition skipDuplicate(boolean)
{
java.lang.Boolean v;
boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: void setSkipDuplicate(java.lang.Boolean)>(v);
return v;
}
public void setExpression(org.apache.camel.model.language.ExpressionDefinition)
{
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.model.language.ExpressionDefinition;
specialinvoke v.<org.apache.camel.model.ExpressionNode: void setExpression(org.apache.camel.model.language.ExpressionDefinition)>(v);
return;
}
public java.lang.String getMessageIdRepositoryRef()
{
java.lang.String v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.String messageIdRepositoryRef>;
return v;
}
public void setMessageIdRepositoryRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.String;
v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.String messageIdRepositoryRef> = v;
return;
}
public org.apache.camel.spi.IdempotentRepository getMessageIdRepository()
{
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository idempotentRepository>;
return v;
}
public void setMessageIdRepository(org.apache.camel.spi.IdempotentRepository)
{
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.spi.IdempotentRepository;
v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository idempotentRepository> = v;
return;
}
public java.lang.Boolean getEager()
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean eager>;
return v;
}
public void setEager(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean eager> = v;
return;
}
public java.lang.Boolean getSkipDuplicate()
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean skipDuplicate>;
return v;
}
public void setSkipDuplicate(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean skipDuplicate> = v;
return;
}
public java.lang.Boolean getRemoveOnFailure()
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean removeOnFailure>;
return v;
}
public void setRemoveOnFailure(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean removeOnFailure> = v;
return;
}
public java.lang.Boolean getCompletionEager()
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean completionEager>;
return v;
}
public void setCompletionEager(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean completionEager> = v;
return;
}
public org.apache.camel.Processor createProcessor(org.apache.camel.spi.RouteContext) throws java.lang.Exception
{
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.Expression v;
org.apache.camel.processor.idempotent.IdempotentConsumer v;
org.apache.camel.Processor v;
java.lang.Boolean v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
org.apache.camel.model.language.ExpressionDefinition v;
org.apache.camel.model.IdempotentConsumerDefinition v;
org.apache.camel.spi.RouteContext v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.Processor createChildProcessor(org.apache.camel.spi.RouteContext,boolean)>(v, 1);
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository resolveMessageIdRepository(org.apache.camel.spi.RouteContext)>(v);
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String,java.lang.Object)>(v, "idempotentRepository", v);
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: 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.IdempotentConsumerDefinition: java.lang.Boolean getEager()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getEager()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getSkipDuplicate()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getSkipDuplicate()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getRemoveOnFailure()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getRemoveOnFailure()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getCompletionEager()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.Boolean getCompletionEager()>();
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.idempotent.IdempotentConsumer;
specialinvoke v.<org.apache.camel.processor.idempotent.IdempotentConsumer: void <init>(org.apache.camel.Expression,org.apache.camel.spi.IdempotentRepository,boolean,boolean,boolean,boolean,org.apache.camel.Processor)>(v, v, v, v, v, v, v);
return v;
}
protected org.apache.camel.spi.IdempotentRepository resolveMessageIdRepository(org.apache.camel.spi.RouteContext)
{
java.lang.Object v;
java.lang.String v, v;
org.apache.camel.spi.IdempotentRepository v;
org.apache.camel.spi.RouteContext v;
org.apache.camel.model.IdempotentConsumerDefinition v;
v := @this: org.apache.camel.model.IdempotentConsumerDefinition;
v := @parameter: org.apache.camel.spi.RouteContext;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.String messageIdRepositoryRef>;
if v == null goto label;
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: java.lang.String messageIdRepositoryRef>;
v = interfaceinvoke v.<org.apache.camel.spi.RouteContext: java.lang.Object mandatoryLookup(java.lang.String,java.lang.Class)>(v, class "Lorg/apache/camel/spi/IdempotentRepository;");
v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository idempotentRepository> = v;
label:
v = v.<org.apache.camel.model.IdempotentConsumerDefinition: org.apache.camel.spi.IdempotentRepository idempotentRepository>;
return v;
}
}