public class org.apache.camel.impl.DefaultScheduledPollConsumer extends org.apache.camel.impl.ScheduledPollConsumer
{
private org.apache.camel.PollingConsumer pollingConsumer;
private int timeout;
public void <init>(org.apache.camel.impl.DefaultEndpoint, org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.impl.DefaultEndpoint v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v := @parameter: org.apache.camel.impl.DefaultEndpoint;
v := @parameter: org.apache.camel.Processor;
specialinvoke v.<org.apache.camel.impl.ScheduledPollConsumer: void <init>(org.apache.camel.Endpoint,org.apache.camel.Processor)>(v, v);
return;
}
public void <init>(org.apache.camel.Endpoint, org.apache.camel.Processor, java.util.concurrent.ScheduledExecutorService)
{
org.apache.camel.Processor v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: org.apache.camel.Processor;
v := @parameter: java.util.concurrent.ScheduledExecutorService;
specialinvoke v.<org.apache.camel.impl.ScheduledPollConsumer: void <init>(org.apache.camel.Endpoint,org.apache.camel.Processor,java.util.concurrent.ScheduledExecutorService)>(v, v, v);
return;
}
protected int poll() throws java.lang.Exception
{
org.apache.camel.Message v, v;
org.apache.camel.PollingConsumer v, v, v;
org.apache.camel.Exchange v, v;
org.apache.camel.Endpoint v;
java.lang.Integer v;
org.apache.camel.Processor v;
int v, v, v, v;
boolean v, v;
org.slf4j.Logger v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v = 0;
label:
v = virtualinvoke v.<org.apache.camel.impl.DefaultScheduledPollConsumer: boolean isPollAllowed()>();
if v == 0 goto label;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: int timeout>;
if v != 0 goto label;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer>;
v = interfaceinvoke v.<org.apache.camel.PollingConsumer: org.apache.camel.Exchange receiveNoWait()>();
goto label;
label:
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: int timeout>;
if v >= 0 goto label;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer>;
v = interfaceinvoke v.<org.apache.camel.PollingConsumer: org.apache.camel.Exchange receive()>();
goto label;
label:
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer>;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: int timeout>;
v = interfaceinvoke v.<org.apache.camel.PollingConsumer: org.apache.camel.Exchange receive(long)>(v);
label:
if v == null goto label;
v = v + 1;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.slf4j.Logger log>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Polled {} {}", v, v);
v = interfaceinvoke v.<org.apache.camel.Exchange: boolean hasOut()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.Exchange createExchange()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getOut()>();
interfaceinvoke v.<org.apache.camel.Message: void copyFrom(org.apache.camel.Message)>(v);
v = v;
label:
v = virtualinvoke v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.Processor getProcessor()>();
interfaceinvoke v.<org.apache.camel.Processor: void process(org.apache.camel.Exchange)>(v);
goto label;
label:
return v;
}
public int getTimeout()
{
int v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: int timeout>;
return v;
}
public void setTimeout(int)
{
int v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v := @parameter: int;
v.<org.apache.camel.impl.DefaultScheduledPollConsumer: int timeout> = v;
return;
}
protected void doStart() throws java.lang.Exception
{
org.apache.camel.impl.DefaultScheduledPollConsumer v;
org.apache.camel.PollingConsumer v, v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v = virtualinvoke v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.PollingConsumer createPollingConsumer()>();
v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer> = v;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer>;
staticinvoke <org.apache.camel.util.ServiceHelper: void startService(org.apache.camel.Service)>(v);
specialinvoke v.<org.apache.camel.impl.ScheduledPollConsumer: void doStart()>();
return;
}
protected void doStop() throws java.lang.Exception
{
org.apache.camel.PollingConsumer v;
org.apache.camel.impl.DefaultScheduledPollConsumer v;
v := @this: org.apache.camel.impl.DefaultScheduledPollConsumer;
v = v.<org.apache.camel.impl.DefaultScheduledPollConsumer: org.apache.camel.PollingConsumer pollingConsumer>;
staticinvoke <org.apache.camel.util.ServiceHelper: void stopService(java.lang.Object)>(v);
specialinvoke v.<org.apache.camel.impl.ScheduledPollConsumer: void doStop()>();
return;
}
}