public abstract class org.apache.camel.impl.ScheduledBatchPollingConsumer extends org.apache.camel.impl.ScheduledPollConsumer implements org.apache.camel.BatchConsumer, org.apache.camel.spi.ShutdownAware
{
private static final org.slf4j.Logger LOG;
protected volatile org.apache.camel.ShutdownRunningTask shutdownRunningTask;
protected volatile int pendingExchanges;
protected int maxMessagesPerPoll;
public void <init>(org.apache.camel.Endpoint, org.apache.camel.Processor)
{
org.apache.camel.Processor v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v := @parameter: org.apache.camel.Endpoint;
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;
java.util.concurrent.ScheduledExecutorService v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
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;
}
public boolean deferShutdown(org.apache.camel.ShutdownRunningTask)
{
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.ShutdownRunningTask v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v := @parameter: org.apache.camel.ShutdownRunningTask;
v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.ShutdownRunningTask shutdownRunningTask> = v;
return 0;
}
public int getPendingExchangesSize()
{
org.slf4j.Logger v;
int v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.ShutdownRunningTask v, v;
boolean v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v = <org.apache.camel.ShutdownRunningTask: org.apache.camel.ShutdownRunningTask CompleteAllTasks>;
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.ShutdownRunningTask shutdownRunningTask>;
if v != v goto label;
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: int pendingExchanges>;
goto label;
label:
v = 0;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: boolean isPolling()>();
if v == 0 goto label;
v = <org.apache.camel.impl.ScheduledBatchPollingConsumer: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("Currently polling so returning 1 as pending exchanges");
v = 1;
label:
return v;
}
public void prepareShutdown(boolean, boolean)
{
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
boolean v, v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v := @parameter: boolean;
v := @parameter: boolean;
v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.ShutdownRunningTask shutdownRunningTask> = null;
return;
}
public void setMaxMessagesPerPoll(int)
{
int v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v := @parameter: int;
v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: int maxMessagesPerPoll> = v;
return;
}
public int getMaxMessagesPerPoll()
{
int v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: int maxMessagesPerPoll>;
return v;
}
public boolean isBatchAllowed()
{
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.ShutdownRunningTask v, v, v;
boolean v, v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: boolean isRunAllowed()>();
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.ShutdownRunningTask shutdownRunningTask>;
if v != null goto label;
return 1;
label:
v = <org.apache.camel.ShutdownRunningTask: org.apache.camel.ShutdownRunningTask CompleteAllTasks>;
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.ShutdownRunningTask shutdownRunningTask>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected void processEmptyMessage() throws java.lang.Exception
{
org.slf4j.Logger v;
org.apache.camel.Exchange v;
org.apache.camel.impl.ScheduledBatchPollingConsumer v;
org.apache.camel.Endpoint v, v;
java.lang.Integer v, v;
org.apache.camel.Processor v;
java.lang.Boolean v;
v := @this: org.apache.camel.impl.ScheduledBatchPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.Exchange createExchange()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>("CamelBatchIndex", v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>("CamelBatchSize", v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
interfaceinvoke v.<org.apache.camel.Exchange: void setProperty(java.lang.String,java.lang.Object)>("CamelBatchComplete", v);
v = v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.slf4j.Logger log>;
v = virtualinvoke v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.Endpoint getEndpoint()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Sending empty message as there were no messages from polling: {}", v);
v = virtualinvoke v.<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.apache.camel.Processor getProcessor()>();
interfaceinvoke v.<org.apache.camel.Processor: void process(org.apache.camel.Exchange)>(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/impl/ScheduledBatchPollingConsumer;");
<org.apache.camel.impl.ScheduledBatchPollingConsumer: org.slf4j.Logger LOG> = v;
return;
}
}