public abstract class org.apache.camel.impl.ScheduledPollEndpoint extends org.apache.camel.impl.DefaultEndpoint
{
private static final java.lang.String SPRING_SCHEDULER;
private static final java.lang.String QUARTZ_2_SCHEDULER;
private boolean startScheduler;
private long initialDelay;
private long delay;
private java.util.concurrent.TimeUnit timeUnit;
private boolean useFixedDelay;
private org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy;
private org.apache.camel.LoggingLevel runLoggingLevel;
private boolean sendEmptyMessageWhenIdle;
private boolean greedy;
private org.apache.camel.spi.ScheduledPollConsumerScheduler scheduler;
private java.lang.String schedulerName;
private java.util.Map schedulerProperties;
private java.util.concurrent.ScheduledExecutorService scheduledExecutorService;
private int backoffMultiplier;
private int backoffIdleThreshold;
private int backoffErrorThreshold;
protected void <init>(java.lang.String, org.apache.camel.Component)
{
java.util.concurrent.TimeUnit v;
org.apache.camel.LoggingLevel v;
org.apache.camel.impl.DefaultPollingConsumerPollStrategy v;
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.Component v;
java.lang.String v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.Component;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void <init>(java.lang.String,org.apache.camel.Component)>(v, v);
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler> = 1;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay> = 1000L;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay> = 500L;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay> = 1;
v = new org.apache.camel.impl.DefaultPollingConsumerPollStrategy;
specialinvoke v.<org.apache.camel.impl.DefaultPollingConsumerPollStrategy: void <init>()>();
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy> = v;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel TRACE>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName> = "none";
return;
}
protected void <init>(java.lang.String, org.apache.camel.CamelContext)
{
java.util.concurrent.TimeUnit v;
org.apache.camel.LoggingLevel v;
org.apache.camel.CamelContext v;
org.apache.camel.impl.DefaultPollingConsumerPollStrategy v;
org.apache.camel.impl.ScheduledPollEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.CamelContext;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void <init>(java.lang.String,org.apache.camel.CamelContext)>(v, v);
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler> = 1;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay> = 1000L;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay> = 500L;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay> = 1;
v = new org.apache.camel.impl.DefaultPollingConsumerPollStrategy;
specialinvoke v.<org.apache.camel.impl.DefaultPollingConsumerPollStrategy: void <init>()>();
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy> = v;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel TRACE>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName> = "none";
return;
}
protected void <init>(java.lang.String)
{
java.util.concurrent.TimeUnit v;
org.apache.camel.LoggingLevel v;
org.apache.camel.impl.DefaultPollingConsumerPollStrategy v;
org.apache.camel.impl.ScheduledPollEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void <init>(java.lang.String)>(v);
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler> = 1;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay> = 1000L;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay> = 500L;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay> = 1;
v = new org.apache.camel.impl.DefaultPollingConsumerPollStrategy;
specialinvoke v.<org.apache.camel.impl.DefaultPollingConsumerPollStrategy: void <init>()>();
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy> = v;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel TRACE>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName> = "none";
return;
}
protected void <init>()
{
java.util.concurrent.TimeUnit v;
org.apache.camel.LoggingLevel v;
org.apache.camel.impl.DefaultPollingConsumerPollStrategy v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void <init>()>();
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler> = 1;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay> = 1000L;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay> = 500L;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay> = 1;
v = new org.apache.camel.impl.DefaultPollingConsumerPollStrategy;
specialinvoke v.<org.apache.camel.impl.DefaultPollingConsumerPollStrategy: void <init>()>();
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy> = v;
v = <org.apache.camel.LoggingLevel: org.apache.camel.LoggingLevel TRACE>;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel> = v;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName> = "none";
return;
}
public void configureProperties(java.util.Map)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
java.util.Map v, v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void configureProperties(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map getConsumerProperties()>();
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void configureScheduledPollConsumerProperties(java.util.Map,java.util.Map)>(v, v);
return;
}
protected void configureScheduledPollConsumerProperties(java.util.Map, java.util.Map)
{
org.apache.camel.spi.ClassResolver v, v;
java.util.Map v, v, v;
boolean v, v, v, v;
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.Injector v, v;
org.apache.camel.spi.ScheduledPollConsumerScheduler v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.camel.CamelContext v, v, v, v, v;
java.lang.IllegalArgumentException v, v;
java.lang.Class v, v;
java.lang.ClassNotFoundException v, v;
java.lang.Object v, v, v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.util.Map;
v := @parameter: java.util.Map;
v = staticinvoke <org.apache.camel.util.IntrospectionSupport: java.util.Map extractProperties(java.util.Map,java.lang.String)>(v, "scheduler.");
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void setSchedulerProperties(java.util.Map)>(v);
label:
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.ScheduledPollConsumerScheduler scheduler>;
if v != null goto label;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName>;
if v == null goto label;
v = "none";
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.ScheduledPollConsumerScheduler scheduler> = null;
goto label;
label:
v = "spring";
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ClassResolver getClassResolver()>();
v = interfaceinvoke v.<org.apache.camel.spi.ClassResolver: java.lang.Class resolveMandatoryClass(java.lang.String,java.lang.Class)>("org.apache.camel.spring.pollingconsumer.SpringScheduledPollConsumerScheduler", class "Lorg/apache/camel/spi/ScheduledPollConsumerScheduler;");
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.Injector getInjector()>();
v = interfaceinvoke v.<org.apache.camel.spi.Injector: java.lang.Object newInstance(java.lang.Class)>(v);
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void setScheduler(org.apache.camel.spi.ScheduledPollConsumerScheduler)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String,java.lang.Throwable)>("Cannot load org.apache.camel.spring.pollingconsumer.SpringScheduledPollConsumerScheduler from classpath. Make sure camel-spring.jar is on the classpath.", v);
throw v;
label:
v = "quartz2";
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.ClassResolver getClassResolver()>();
v = interfaceinvoke v.<org.apache.camel.spi.ClassResolver: java.lang.Class resolveMandatoryClass(java.lang.String,java.lang.Class)>("org.apache.camel.pollconsumer.quartz.QuartzScheduledPollConsumerScheduler", class "Lorg/apache/camel/spi/ScheduledPollConsumerScheduler;");
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.Injector getInjector()>();
v = interfaceinvoke v.<org.apache.camel.spi.Injector: java.lang.Object newInstance(java.lang.Class)>(v);
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void setScheduler(org.apache.camel.spi.ScheduledPollConsumerScheduler)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String,java.lang.Throwable)>("Cannot load org.apache.camel.pollconsumer.quartz.QuartzScheduledPollConsumerScheduler from classpath. Make sure camel-quartz.jar is on the classpath.", v);
throw v;
label:
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName>;
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/spi/ScheduledPollConsumerScheduler;");
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void setScheduler(org.apache.camel.spi.ScheduledPollConsumerScheduler)>(v);
label:
return;
catch java.lang.ClassNotFoundException from label to label with label;
catch java.lang.ClassNotFoundException from label to label with label;
}
protected void configurePollingConsumer(org.apache.camel.PollingConsumer) throws java.lang.Exception
{
org.apache.camel.CamelContext v, v;
org.apache.camel.PollingConsumer v;
org.apache.camel.impl.ScheduledPollEndpoint v;
java.util.HashMap v, v;
java.util.Map v;
int v, v;
java.lang.String v, v;
org.apache.camel.ResolveEndpointFailedException v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: org.apache.camel.PollingConsumer;
v = new java.util.HashMap;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map getConsumerProperties()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void configureScheduledPollConsumerProperties(java.util.Map,java.util.Map)>(v, v);
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
staticinvoke <org.apache.camel.util.EndpointHelper: void setReferenceProperties(org.apache.camel.CamelContext,java.lang.Object,java.util.Map)>(v, v, v);
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.CamelContext getCamelContext()>();
staticinvoke <org.apache.camel.util.EndpointHelper: void setProperties(org.apache.camel.CamelContext,java.lang.Object,java.util.Map)>(v, v, v);
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean isLenientProperties()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map: int size()>();
if v <= 0 goto label;
v = new org.apache.camel.ResolveEndpointFailedException;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String getEndpointUri()>();
v = interfaceinvoke v.<java.util.Map: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.util.HashMap)>(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[])>("There are \u parameters that couldn\'t be set on the endpoint polling consumer. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown consumer parameters=[\u]");
specialinvoke v.<org.apache.camel.ResolveEndpointFailedException: void <init>(java.lang.String,java.lang.String)>(v, v);
throw v;
label:
return;
}
protected void initConsumerProperties()
{
java.lang.Integer v, v, v;
java.lang.Long v, v;
java.util.Map v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.camel.LoggingLevel v;
org.apache.camel.spi.PollingConsumerPollStrategy v;
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.ScheduledPollConsumerScheduler v;
long v, v;
int v, v, v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.Boolean v, v, v, v;
java.util.concurrent.TimeUnit v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map getConsumerProperties()>();
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("startScheduler");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean isStartScheduler()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("startScheduler", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("initialDelay");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: long getInitialDelay()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("initialDelay", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("delay");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: long getDelay()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delay", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("timeUnit");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit getTimeUnit()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("timeUnit", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("useFixedDelay");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean isUseFixedDelay()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("useFixedDelay", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("pollStrategy");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy getPollStrategy()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("pollStrategy", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("runLoggingLevel");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel getRunLoggingLevel()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("runLoggingLevel", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("sendEmptyMessageWhenIdle");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean isSendEmptyMessageWhenIdle()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("sendEmptyMessageWhenIdle", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("greedy");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean isGreedy()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("greedy", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("scheduler");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.ScheduledPollConsumerScheduler getScheduler()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("scheduler", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("schedulerProperties");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map getSchedulerProperties()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("schedulerProperties", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("scheduledExecutorService");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.ScheduledExecutorService getScheduledExecutorService()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("scheduledExecutorService", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("backoffMultiplier");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: int getBackoffMultiplier()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("backoffMultiplier", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("backoffIdleThreshold");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: int getBackoffIdleThreshold()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("backoffIdleThreshold", v);
label:
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("backoffErrorThreshold");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: int getBackoffErrorThreshold()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("backoffErrorThreshold", v);
label:
return;
}
protected void doStart() throws java.lang.Exception
{
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
virtualinvoke v.<org.apache.camel.impl.ScheduledPollEndpoint: void initConsumerProperties()>();
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void doStart()>();
return;
}
protected void doStop() throws java.lang.Exception
{
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
specialinvoke v.<org.apache.camel.impl.DefaultEndpoint: void doStop()>();
return;
}
public boolean isStartScheduler()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler>;
return v;
}
public void setStartScheduler(boolean)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean startScheduler> = v;
return;
}
public long getInitialDelay()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
long v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay>;
return v;
}
public void setInitialDelay(long)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
long v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: long;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long initialDelay> = v;
return;
}
public long getDelay()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
long v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay>;
return v;
}
public void setDelay(long)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
long v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: long;
v.<org.apache.camel.impl.ScheduledPollEndpoint: long delay> = v;
return;
}
public java.util.concurrent.TimeUnit getTimeUnit()
{
java.util.concurrent.TimeUnit v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit>;
return v;
}
public void setTimeUnit(java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.util.concurrent.TimeUnit;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.TimeUnit timeUnit> = v;
return;
}
public boolean isUseFixedDelay()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay>;
return v;
}
public void setUseFixedDelay(boolean)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean useFixedDelay> = v;
return;
}
public org.apache.camel.spi.PollingConsumerPollStrategy getPollStrategy()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.PollingConsumerPollStrategy v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy>;
return v;
}
public void setPollStrategy(org.apache.camel.spi.PollingConsumerPollStrategy)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.PollingConsumerPollStrategy v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: org.apache.camel.spi.PollingConsumerPollStrategy;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy> = v;
return;
}
public org.apache.camel.LoggingLevel getRunLoggingLevel()
{
org.apache.camel.LoggingLevel v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel>;
return v;
}
public void setRunLoggingLevel(org.apache.camel.LoggingLevel)
{
org.apache.camel.LoggingLevel v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: org.apache.camel.LoggingLevel;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.LoggingLevel runLoggingLevel> = v;
return;
}
public boolean isSendEmptyMessageWhenIdle()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean sendEmptyMessageWhenIdle>;
return v;
}
public void setSendEmptyMessageWhenIdle(boolean)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean sendEmptyMessageWhenIdle> = v;
return;
}
public boolean isGreedy()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean greedy>;
return v;
}
public void setGreedy(boolean)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.impl.ScheduledPollEndpoint: boolean greedy> = v;
return;
}
public org.apache.camel.spi.ScheduledPollConsumerScheduler getScheduler()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.ScheduledPollConsumerScheduler v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.ScheduledPollConsumerScheduler scheduler>;
return v;
}
public void setScheduler(org.apache.camel.spi.ScheduledPollConsumerScheduler)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
org.apache.camel.spi.ScheduledPollConsumerScheduler v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: org.apache.camel.spi.ScheduledPollConsumerScheduler;
v.<org.apache.camel.impl.ScheduledPollEndpoint: org.apache.camel.spi.ScheduledPollConsumerScheduler scheduler> = v;
return;
}
public void setScheduler(java.lang.String)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.lang.String;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.lang.String schedulerName> = v;
return;
}
public java.util.Map getSchedulerProperties()
{
org.apache.camel.impl.ScheduledPollEndpoint v;
java.util.Map v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map schedulerProperties>;
return v;
}
public void setSchedulerProperties(java.util.Map)
{
org.apache.camel.impl.ScheduledPollEndpoint v;
java.util.Map v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.util.Map;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.Map schedulerProperties> = v;
return;
}
public java.util.concurrent.ScheduledExecutorService getScheduledExecutorService()
{
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.ScheduledExecutorService scheduledExecutorService>;
return v;
}
public void setScheduledExecutorService(java.util.concurrent.ScheduledExecutorService)
{
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
v.<org.apache.camel.impl.ScheduledPollEndpoint: java.util.concurrent.ScheduledExecutorService scheduledExecutorService> = v;
return;
}
public int getBackoffMultiplier()
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffMultiplier>;
return v;
}
public void setBackoffMultiplier(int)
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: int;
v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffMultiplier> = v;
return;
}
public int getBackoffIdleThreshold()
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffIdleThreshold>;
return v;
}
public void setBackoffIdleThreshold(int)
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: int;
v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffIdleThreshold> = v;
return;
}
public int getBackoffErrorThreshold()
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v = v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffErrorThreshold>;
return v;
}
public void setBackoffErrorThreshold(int)
{
int v;
org.apache.camel.impl.ScheduledPollEndpoint v;
v := @this: org.apache.camel.impl.ScheduledPollEndpoint;
v := @parameter: int;
v.<org.apache.camel.impl.ScheduledPollEndpoint: int backoffErrorThreshold> = v;
return;
}
}