public class org.apache.camel.processor.RedeliveryPolicy extends java.lang.Object implements java.lang.Cloneable, java.io.Serializable
{
protected static java.util.Random randomNumberGenerator;
private static final long serialVersionUID;
private static final org.slf4j.Logger LOG;
protected long redeliveryDelay;
protected int maximumRedeliveries;
protected long maximumRedeliveryDelay;
protected double backOffMultiplier;
protected boolean useExponentialBackOff;
protected double collisionAvoidanceFactor;
protected boolean useCollisionAvoidance;
protected org.apache.camel.LoggingLevel retriesExhaustedLogLevel;
protected org.apache.camel.LoggingLevel retryAttemptedLogLevel;
protected int retryAttemptedLogInterval;
protected boolean logStackTrace;
protected boolean logRetryStackTrace;
protected boolean logHandled;
protected boolean logContinued;
protected boolean logExhausted;
protected boolean logNewException;
protected java.lang.Boolean logExhaustedMessageHistory;
protected java.lang.Boolean logExhaustedMessageBody;
protected boolean logRetryAttempted;
protected java.lang.String delayPattern;
protected boolean asyncDelayedRedelivery;
protected boolean allowRedeliveryWhileStopping;
protected java.lang.String exchangeFormatterRef;
public void <init>()
{
org.apache.camel.LoggingLevel v, v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.processor.RedeliveryPolicy: long redeliveryDelay> = 1000L;
v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay> = 60000L;
v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier> = 2.0;
v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor> = 0.15;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel ERROR>;
v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retriesExhaustedLogLevel> = v;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel DEBUG>;
v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retryAttemptedLogLevel> = v;
v.<org.apache.camel.processor.RedeliveryPolicy: int retryAttemptedLogInterval> = 1;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logStackTrace> = 1;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logExhausted> = 1;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logNewException> = 1;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryAttempted> = 1;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean allowRedeliveryWhileStopping> = 1;
return;
}
public java.lang.String toString()
{
long v, v;
int v, v;
java.lang.Boolean v, v;
java.lang.String v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v;
double v, v;
org.apache.camel.LoggingLevel v, v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: int maximumRedeliveries>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long redeliveryDelay>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean asyncDelayedRedelivery>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean allowRedeliveryWhileStopping>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retriesExhaustedLogLevel>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retryAttemptedLogLevel>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: int retryAttemptedLogInterval>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryAttempted>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logStackTrace>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryStackTrace>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logHandled>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logContinued>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logExhausted>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logNewException>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageHistory>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageBody>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useExponentialBackOff>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useCollisionAvoidance>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String delayPattern>;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String exchangeFormatterRef>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,long,long,boolean,boolean,org.apache.camel.LoggingLevel,org.apache.camel.LoggingLevel,int,boolean,boolean,boolean,boolean,boolean,boolean,boolean,java.lang.Boolean,java.lang.Boolean,boolean,double,boolean,double,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, 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[])>("RedeliveryPolicy[maximumRedeliveries=\u, redeliveryDelay=\u, maximumRedeliveryDelay=\u, asyncDelayedRedelivery=\u, allowRedeliveryWhileStopping=\u, retriesExhaustedLogLevel=\u, retryAttemptedLogLevel=\u, retryAttemptedLogInterval=\u, logRetryAttempted=\u, logStackTrace=\u, logRetryStackTrace=\u, logHandled=\u, logContinued=\u, logExhausted=\u, logNewException=\u, logExhaustedMessageHistory=\u, logExhaustedMessageBody=\u, useExponentialBackOff=\u, backOffMultiplier=\u, useCollisionAvoidance=\u, collisionAvoidanceFactor=\u, delayPattern=\u, exchangeFormatterRef=\u]");
return v;
}
public org.apache.camel.processor.RedeliveryPolicy copy()
{
java.lang.Object v;
java.lang.RuntimeException v;
java.lang.String v;
java.lang.CloneNotSupportedException v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Object clone()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.CloneNotSupportedException)>(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[])>("Could not clone: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.CloneNotSupportedException from label to label with label;
}
public boolean shouldRedeliver(org.apache.camel.Exchange, int, org.apache.camel.Predicate)
{
org.apache.camel.Exchange v;
org.apache.camel.processor.RedeliveryPolicy v;
org.apache.camel.Predicate v;
int v, v, v;
boolean v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: int;
v := @parameter: org.apache.camel.Predicate;
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.Predicate: boolean matches(org.apache.camel.Exchange)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: int getMaximumRedeliveries()>();
if v >= 0 goto label;
return 1;
label:
v = virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: int getMaximumRedeliveries()>();
if v > v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long sleep(long, int) throws java.lang.InterruptedException
{
byte v;
int v;
long v, v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v := @parameter: int;
v = virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: long calculateRedeliveryDelay(long,int)>(v, v);
v = v cmp 0L;
if v <= 0 goto label;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void sleep(long)>(v);
label:
return v;
}
public void sleep(long) throws java.lang.InterruptedException
{
org.slf4j.Logger v;
java.lang.Long v;
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v = <org.apache.camel.processor.RedeliveryPolicy: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Sleeping for: {} millis until attempting redelivery", v);
staticinvoke <java.lang.Thread: void sleep(long)>(v);
return;
}
public long calculateRedeliveryDelay(long, int)
{
java.util.Random v;
long v, v, v, v, v;
byte v, v, v, v;
int v;
java.lang.String v, v;
boolean v, v, v, v;
double v, v, v, v, v, v, v, v, v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v := @parameter: int;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String delayPattern>;
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isNotEmpty(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String delayPattern>;
v = staticinvoke <org.apache.camel.processor.RedeliveryPolicy: long calculateRedeliverDelayUsingPattern(java.lang.String,int)>(v, v);
return v;
label:
v = v cmp 0L;
if v != 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long redeliveryDelay>;
goto label;
label:
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useExponentialBackOff>;
if v == 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier>;
v = v cmpl 1.0;
if v <= 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier>;
v = v * v;
v = staticinvoke <java.lang.Math: long round(double)>(v);
goto label;
label:
v = v;
label:
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useCollisionAvoidance>;
if v == 0 goto label;
v = staticinvoke <org.apache.camel.processor.RedeliveryPolicy: java.util.Random getRandomNumberGenerator()>();
v = virtualinvoke v.<java.util.Random: boolean nextBoolean()>();
if v == 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor>;
goto label;
label:
v = v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor>;
v = neg v;
label:
v = virtualinvoke v.<java.util.Random: double nextDouble()>();
v = v * v;
v = v * v;
v = v + v;
label:
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
v = v cmp v;
if v <= 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
label:
return v;
}
protected static long calculateRedeliverDelayUsingPattern(java.lang.String, int)
{
java.lang.String[] v;
long v, v;
java.lang.Integer v;
java.lang.Long v;
int v, v, v, v;
java.lang.String v, v, v, v;
v := @parameter: java.lang.String;
v := @parameter: int;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(";");
v = 0L;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.camel.util.StringHelper: java.lang.String after(java.lang.String,java.lang.String)>(v, ":");
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = staticinvoke <org.apache.camel.util.StringHelper: java.lang.String before(java.lang.String,java.lang.String)>(v, ":");
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v > v goto label;
v = v;
v = v + 1;
goto label;
label:
return v;
}
public org.apache.camel.processor.RedeliveryPolicy redeliverDelay(long)
{
long v;
org.apache.camel.processor.RedeliveryPolicy v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v = virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.processor.RedeliveryPolicy redeliveryDelay(long)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy redeliveryDelay(long)
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setRedeliveryDelay(long)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy maximumRedeliveries(int)
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: int;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setMaximumRedeliveries(int)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy useCollisionAvoidance()
{
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setUseCollisionAvoidance(boolean)>(1);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy useExponentialBackOff()
{
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setUseExponentialBackOff(boolean)>(1);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy backOffMultiplier(double)
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: double;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.processor.RedeliveryPolicy useExponentialBackOff()>();
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setBackOffMultiplier(double)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy collisionAvoidancePercent(double)
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: double;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.processor.RedeliveryPolicy useCollisionAvoidance()>();
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setCollisionAvoidancePercent(double)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy maximumRedeliveryDelay(long)
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setMaximumRedeliveryDelay(long)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy retriesExhaustedLogLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: org.apache.camel.LoggingLevel;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setRetriesExhaustedLogLevel(org.apache.camel.LoggingLevel)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy retryAttemptedLogLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: org.apache.camel.LoggingLevel;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setRetryAttemptedLogLevel(org.apache.camel.LoggingLevel)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy retryAttemptedLogInterval(int)
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: int;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setRetryAttemptedLogInterval(int)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logRetryAttempted(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogRetryAttempted(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logStackTrace(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogStackTrace(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logRetryStackTrace(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogRetryStackTrace(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logHandled(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogHandled(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logNewException(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogNewException(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logExhausted(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogExhausted(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logExhaustedMessageHistory(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogExhaustedMessageHistory(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy logExhaustedMessageBody(boolean)
{
java.lang.Boolean v;
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setLogExhaustedMessageBody(java.lang.Boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy delayPattern(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setDelayPattern(java.lang.String)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy disableRedelivery()
{
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setMaximumRedeliveries(int)>(0);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy asyncDelayedRedelivery()
{
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setAsyncDelayedRedelivery(boolean)>(1);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy allowRedeliveryWhileStopping(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setAllowRedeliveryWhileStopping(boolean)>(v);
return v;
}
public org.apache.camel.processor.RedeliveryPolicy exchangeFormatterRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setExchangeFormatterRef(java.lang.String)>(v);
return v;
}
public long getRedeliverDelay()
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: long getRedeliveryDelay()>();
return v;
}
public void setRedeliverDelay(long)
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
virtualinvoke v.<org.apache.camel.processor.RedeliveryPolicy: void setRedeliveryDelay(long)>(v);
return;
}
public long getRedeliveryDelay()
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long redeliveryDelay>;
return v;
}
public void setRedeliveryDelay(long)
{
byte v, v;
long v, v, v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v.<org.apache.camel.processor.RedeliveryPolicy: long redeliveryDelay> = v;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
v = v cmp v;
if v <= 0 goto label;
v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay> = v;
label:
return;
}
public double getBackOffMultiplier()
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier>;
return v;
}
public void setBackOffMultiplier(double)
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: double;
v.<org.apache.camel.processor.RedeliveryPolicy: double backOffMultiplier> = v;
return;
}
public long getCollisionAvoidancePercent()
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
double v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor>;
v = v * 100.0;
v = staticinvoke <java.lang.Math: long round(double)>(v);
return v;
}
public void setCollisionAvoidancePercent(double)
{
org.apache.camel.processor.RedeliveryPolicy v;
double v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: double;
v = v * 0.01;
v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor> = v;
return;
}
public double getCollisionAvoidanceFactor()
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor>;
return v;
}
public void setCollisionAvoidanceFactor(double)
{
org.apache.camel.processor.RedeliveryPolicy v;
double v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: double;
v.<org.apache.camel.processor.RedeliveryPolicy: double collisionAvoidanceFactor> = v;
return;
}
public int getMaximumRedeliveries()
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: int maximumRedeliveries>;
return v;
}
public void setMaximumRedeliveries(int)
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: int;
v.<org.apache.camel.processor.RedeliveryPolicy: int maximumRedeliveries> = v;
return;
}
public long getMaximumRedeliveryDelay()
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay>;
return v;
}
public void setMaximumRedeliveryDelay(long)
{
long v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: long;
v.<org.apache.camel.processor.RedeliveryPolicy: long maximumRedeliveryDelay> = v;
return;
}
public boolean isUseCollisionAvoidance()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useCollisionAvoidance>;
return v;
}
public void setUseCollisionAvoidance(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean useCollisionAvoidance> = v;
return;
}
public boolean isUseExponentialBackOff()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean useExponentialBackOff>;
return v;
}
public void setUseExponentialBackOff(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean useExponentialBackOff> = v;
return;
}
protected static synchronized java.util.Random getRandomNumberGenerator()
{
java.util.Random v, v, v;
v = <org.apache.camel.processor.RedeliveryPolicy: java.util.Random randomNumberGenerator>;
if v != null goto label;
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
<org.apache.camel.processor.RedeliveryPolicy: java.util.Random randomNumberGenerator> = v;
label:
v = <org.apache.camel.processor.RedeliveryPolicy: java.util.Random randomNumberGenerator>;
return v;
}
public void setRetriesExhaustedLogLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: org.apache.camel.LoggingLevel;
v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retriesExhaustedLogLevel> = v;
return;
}
public org.apache.camel.LoggingLevel getRetriesExhaustedLogLevel()
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retriesExhaustedLogLevel>;
return v;
}
public void setRetryAttemptedLogLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: org.apache.camel.LoggingLevel;
v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retryAttemptedLogLevel> = v;
return;
}
public org.apache.camel.LoggingLevel getRetryAttemptedLogLevel()
{
org.apache.camel.LoggingLevel v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: org.apache.camel.LoggingLevel retryAttemptedLogLevel>;
return v;
}
public int getRetryAttemptedLogInterval()
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: int retryAttemptedLogInterval>;
return v;
}
public void setRetryAttemptedLogInterval(int)
{
int v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: int;
v.<org.apache.camel.processor.RedeliveryPolicy: int retryAttemptedLogInterval> = v;
return;
}
public java.lang.String getDelayPattern()
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String delayPattern>;
return v;
}
public void setDelayPattern(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: java.lang.String;
v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String delayPattern> = v;
return;
}
public boolean isLogStackTrace()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logStackTrace>;
return v;
}
public void setLogStackTrace(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logStackTrace> = v;
return;
}
public boolean isLogRetryStackTrace()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryStackTrace>;
return v;
}
public void setLogRetryStackTrace(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryStackTrace> = v;
return;
}
public boolean isLogHandled()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logHandled>;
return v;
}
public void setLogHandled(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logHandled> = v;
return;
}
public boolean isLogNewException()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logNewException>;
return v;
}
public void setLogNewException(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logNewException> = v;
return;
}
public boolean isLogContinued()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logContinued>;
return v;
}
public void setLogContinued(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logContinued> = v;
return;
}
public boolean isLogRetryAttempted()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryAttempted>;
return v;
}
public void setLogRetryAttempted(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logRetryAttempted> = v;
return;
}
public boolean isLogExhausted()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean logExhausted>;
return v;
}
public void setLogExhausted(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean logExhausted> = v;
return;
}
public boolean isLogExhaustedMessageHistory()
{
java.lang.Boolean v, v;
org.apache.camel.processor.RedeliveryPolicy v;
boolean v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageHistory>;
if v == null goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageHistory>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.Boolean getLogExhaustedMessageHistory()
{
java.lang.Boolean v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageHistory>;
return v;
}
public void setLogExhaustedMessageHistory(boolean)
{
java.lang.Boolean v;
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageHistory> = v;
return;
}
public boolean isLogExhaustedMessageBody()
{
java.lang.Boolean v, v;
org.apache.camel.processor.RedeliveryPolicy v;
boolean v, v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageBody>;
if v == null goto label;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageBody>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.Boolean getLogExhaustedMessageBody()
{
java.lang.Boolean v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageBody>;
return v;
}
public void setLogExhaustedMessageBody(java.lang.Boolean)
{
java.lang.Boolean v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: java.lang.Boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.Boolean logExhaustedMessageBody> = v;
return;
}
public boolean isAsyncDelayedRedelivery()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean asyncDelayedRedelivery>;
return v;
}
public void setAsyncDelayedRedelivery(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean asyncDelayedRedelivery> = v;
return;
}
public boolean isAllowRedeliveryWhileStopping()
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: boolean allowRedeliveryWhileStopping>;
return v;
}
public void setAllowRedeliveryWhileStopping(boolean)
{
org.apache.camel.processor.RedeliveryPolicy v;
boolean v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: boolean;
v.<org.apache.camel.processor.RedeliveryPolicy: boolean allowRedeliveryWhileStopping> = v;
return;
}
public java.lang.String getExchangeFormatterRef()
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v = v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String exchangeFormatterRef>;
return v;
}
public void setExchangeFormatterRef(java.lang.String)
{
java.lang.String v;
org.apache.camel.processor.RedeliveryPolicy v;
v := @this: org.apache.camel.processor.RedeliveryPolicy;
v := @parameter: java.lang.String;
v.<org.apache.camel.processor.RedeliveryPolicy: java.lang.String exchangeFormatterRef> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/processor/RedeliveryPolicy;");
<org.apache.camel.processor.RedeliveryPolicy: org.slf4j.Logger LOG> = v;
return;
}
}