public class org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy extends org.apache.camel.management.mbean.ManagedService implements org.apache.camel.api.management.mbean.ManagedThrottlingExceptionRoutePolicyMBean
{
private final org.apache.camel.impl.ThrottlingExceptionRoutePolicy policy;
public void <init>(org.apache.camel.CamelContext, org.apache.camel.impl.ThrottlingExceptionRoutePolicy)
{
org.apache.camel.CamelContext v;
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: org.apache.camel.impl.ThrottlingExceptionRoutePolicy;
specialinvoke v.<org.apache.camel.management.mbean.ManagedService: void <init>(org.apache.camel.CamelContext,org.apache.camel.Service)>(v, v);
v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy policy> = v;
return;
}
public org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy policy>;
return v;
}
public java.lang.Long getHalfOpenAfter()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.Long v;
long v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getHalfOpenAfter()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
return v;
}
public void setHalfOpenAfter(java.lang.Long)
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.Long v;
long v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v := @parameter: java.lang.Long;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: void setHalfOpenAfter(long)>(v);
return;
}
public java.lang.Long getFailureWindow()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.Long v;
long v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getFailureWindow()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
return v;
}
public void setFailureWindow(java.lang.Long)
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.Long v;
long v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v := @parameter: java.lang.Long;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: void setFailureWindow(long)>(v);
return;
}
public java.lang.Integer getFailureThreshold()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
int v;
java.lang.Integer v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: int getFailureThreshold()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
}
public void setFailureThreshold(java.lang.Integer)
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
int v;
java.lang.Integer v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v := @parameter: java.lang.Integer;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: void setFailureThreshold(int)>(v);
return;
}
public java.lang.String currentState()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.String v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: java.lang.String dumpState()>();
return v;
}
public java.lang.String getHalfOpenHandlerName()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
java.lang.Class v;
java.lang.String v;
org.apache.camel.impl.ThrottlingExceptionHalfOpenHandler v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionHalfOpenHandler getHalfOpenHandler()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
return v;
label:
return "";
}
public java.lang.Integer getCurrentFailures()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v;
int v;
java.lang.Integer v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: int getFailures()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
}
public java.lang.Long getLastFailure()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v, v;
long v, v, v, v;
byte v;
java.lang.Long v, v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getLastFailure()>();
v = v cmp 0L;
if v != 0 goto label;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
return v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getLastFailure()>();
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
return v;
}
public java.lang.Long getOpenAt()
{
org.apache.camel.impl.ThrottlingExceptionRoutePolicy v, v;
long v, v, v, v;
byte v;
java.lang.Long v, v;
org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v;
v := @this: org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getOpenedAt()>();
v = v cmp 0L;
if v != 0 goto label;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(0L);
return v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy: org.apache.camel.impl.ThrottlingExceptionRoutePolicy getPolicy()>();
v = virtualinvoke v.<org.apache.camel.impl.ThrottlingExceptionRoutePolicy: long getOpenedAt()>();
v = v - v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
return v;
}
}