public class org.apache.camel.impl.EventDrivenPollingConsumer extends org.apache.camel.impl.PollingConsumerSupport implements org.apache.camel.Processor, org.apache.camel.IsSingleton
{
private static final org.slf4j.Logger LOG;
private final java.util.concurrent.BlockingQueue queue;
private org.apache.camel.spi.ExceptionHandler interruptedExceptionHandler;
private org.apache.camel.Consumer consumer;
private boolean blockWhenFull;
private long blockTimeout;
private final int queueCapacity;
public void <init>(org.apache.camel.Endpoint)
{
org.apache.camel.Endpoint v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: org.apache.camel.Endpoint;
specialinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void <init>(org.apache.camel.Endpoint,int)>(v, 1000);
return;
}
public void <init>(org.apache.camel.Endpoint, int)
{
java.util.concurrent.ArrayBlockingQueue v;
org.apache.camel.CamelContext v;
org.apache.camel.support.LoggingExceptionHandler v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
int v;
org.apache.camel.Endpoint v;
java.util.concurrent.LinkedBlockingQueue v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: int;
specialinvoke v.<org.apache.camel.impl.PollingConsumerSupport: void <init>(org.apache.camel.Endpoint)>(v);
v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean blockWhenFull> = 1;
v.<org.apache.camel.impl.EventDrivenPollingConsumer: int queueCapacity> = v;
if v > 0 goto label;
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue> = v;
goto label;
label:
v = new java.util.concurrent.ArrayBlockingQueue;
specialinvoke v.<java.util.concurrent.ArrayBlockingQueue: void <init>(int)>(v);
v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue> = v;
label:
v = new org.apache.camel.support.LoggingExceptionHandler;
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.support.LoggingExceptionHandler: void <init>(org.apache.camel.CamelContext,java.lang.Class)>(v, class "Lorg/apache/camel/impl/EventDrivenPollingConsumer;");
v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.spi.ExceptionHandler interruptedExceptionHandler> = v;
return;
}
public void <init>(org.apache.camel.Endpoint, java.util.concurrent.BlockingQueue)
{
org.apache.camel.CamelContext v;
org.apache.camel.support.LoggingExceptionHandler v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
int v;
java.util.concurrent.BlockingQueue v;
org.apache.camel.Endpoint v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: java.util.concurrent.BlockingQueue;
specialinvoke v.<org.apache.camel.impl.PollingConsumerSupport: void <init>(org.apache.camel.Endpoint)>(v);
v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean blockWhenFull> = 1;
v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue> = v;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int remainingCapacity()>();
v.<org.apache.camel.impl.EventDrivenPollingConsumer: int queueCapacity> = v;
v = new org.apache.camel.support.LoggingExceptionHandler;
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.CamelContext getCamelContext()>();
specialinvoke v.<org.apache.camel.support.LoggingExceptionHandler: void <init>(org.apache.camel.CamelContext,java.lang.Class)>(v, class "Lorg/apache/camel/impl/EventDrivenPollingConsumer;");
v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.spi.ExceptionHandler interruptedExceptionHandler> = v;
return;
}
public boolean isBlockWhenFull()
{
boolean v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean blockWhenFull>;
return v;
}
public void setBlockWhenFull(boolean)
{
boolean v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: boolean;
v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean blockWhenFull> = v;
return;
}
public long getBlockTimeout()
{
long v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: long blockTimeout>;
return v;
}
public void setBlockTimeout(long)
{
long v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: long;
v.<org.apache.camel.impl.EventDrivenPollingConsumer: long blockTimeout> = v;
return;
}
public int getQueueCapacity()
{
int v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: int queueCapacity>;
return v;
}
public int getQueueSize()
{
int v;
java.util.concurrent.BlockingQueue v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int size()>();
return v;
}
public org.apache.camel.Exchange receiveNoWait()
{
org.apache.camel.Exchange v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Exchange receive(long)>(0L);
return v;
}
public org.apache.camel.Exchange receive()
{
java.lang.Throwable v, v;
org.slf4j.Logger v;
java.util.concurrent.BlockingQueue v;
java.util.concurrent.RejectedExecutionException v;
java.lang.InterruptedException v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
java.lang.Object v;
java.lang.String v, v;
org.apache.camel.ServiceStatus v;
boolean v, v, v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isRunAllowed()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isStarted()>();
if v != 0 goto label;
label:
v = new java.util.concurrent.RejectedExecutionException;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.ServiceStatus getStatus()>();
v = virtualinvoke v.<org.apache.camel.ServiceStatus: java.lang.String name()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.impl.EventDrivenPollingConsumer,java.lang.String)>(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[])>("\u is not started, but in state: \u0001");
specialinvoke v.<java.util.concurrent.RejectedExecutionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isRunAllowed()>();
if v == 0 goto label;
entermonitor v;
label:
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: long beforePoll(long)>(0L);
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object take()>();
label:
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void handleInterruptedException(java.lang.InterruptedException)>(v);
label:
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = <org.apache.camel.impl.EventDrivenPollingConsumer: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("Consumer is not running, so returning null");
return null;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public org.apache.camel.Exchange receive(long)
{
java.lang.Throwable v, v;
java.util.concurrent.BlockingQueue v;
long v, v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.RejectedExecutionException v;
java.lang.InterruptedException v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
java.lang.Object v;
java.lang.String v, v;
org.apache.camel.ServiceStatus v;
boolean v, v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: long;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isRunAllowed()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isStarted()>();
if v != 0 goto label;
label:
v = new java.util.concurrent.RejectedExecutionException;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.ServiceStatus getStatus()>();
v = virtualinvoke v.<org.apache.camel.ServiceStatus: java.lang.String name()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.impl.EventDrivenPollingConsumer,java.lang.String)>(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[])>("\u is not started, but in state: \u0001");
specialinvoke v.<java.util.concurrent.RejectedExecutionException: void <init>(java.lang.String)>(v);
throw v;
label:
entermonitor v;
label:
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: long beforePoll(long)>(v);
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object poll(long,java.util.concurrent.TimeUnit)>(v, v);
label:
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void handleInterruptedException(java.lang.InterruptedException)>(v);
label:
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
exitmonitor v;
label:
return null;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: void afterPoll()>();
throw v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void process(org.apache.camel.Exchange) throws java.lang.Exception
{
long v, v, v;
org.apache.camel.Exchange v;
org.apache.camel.ExchangeTimedOutException v;
byte v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
java.lang.Boolean v;
boolean v, v, v, v, v;
org.slf4j.Logger v;
java.util.concurrent.BlockingQueue v, v, v;
java.util.concurrent.TimeUnit v;
java.lang.InterruptedException v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: org.apache.camel.Exchange;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isBlockWhenFull()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: long getBlockTimeout()>();
v = v cmp 0L;
if v > 0 goto label;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void put(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: long getBlockTimeout()>();
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean offer(java.lang.Object,long,java.util.concurrent.TimeUnit)>(v, v, v);
if v != 0 goto label;
v = new org.apache.camel.ExchangeTimedOutException;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: long getBlockTimeout()>();
specialinvoke v.<org.apache.camel.ExchangeTimedOutException: void <init>(org.apache.camel.Exchange,long)>(v, v);
throw v;
label:
v := @caughtexception;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.slf4j.Logger log>;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isStopping()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: boolean isStopped()>();
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Put interrupted, are we stopping? {}", v);
goto label;
label:
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: boolean add(java.lang.Object)>(v);
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public org.apache.camel.spi.ExceptionHandler getInterruptedExceptionHandler()
{
org.apache.camel.spi.ExceptionHandler v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.spi.ExceptionHandler interruptedExceptionHandler>;
return v;
}
public void setInterruptedExceptionHandler(org.apache.camel.spi.ExceptionHandler)
{
org.apache.camel.spi.ExceptionHandler v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: org.apache.camel.spi.ExceptionHandler;
v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.spi.ExceptionHandler interruptedExceptionHandler> = v;
return;
}
public org.apache.camel.Consumer getDelegateConsumer()
{
org.apache.camel.Consumer v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
return v;
}
protected void handleInterruptedException(java.lang.InterruptedException)
{
org.apache.camel.spi.ExceptionHandler v;
java.lang.InterruptedException v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: java.lang.InterruptedException;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.spi.ExceptionHandler getInterruptedExceptionHandler()>();
interfaceinvoke v.<org.apache.camel.spi.ExceptionHandler: void handleException(java.lang.Throwable)>(v);
return;
}
protected long beforePoll(long)
{
org.slf4j.Logger v;
long v;
java.lang.Exception v;
org.apache.camel.Consumer v, v, v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
java.lang.String v;
boolean v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v := @parameter: long;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
v = v instanceof org.apache.camel.PollingConsumerPollingStrategy;
if v == 0 goto label;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
label:
v = interfaceinvoke v.<org.apache.camel.PollingConsumerPollingStrategy: long beforePoll(long)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.camel.impl.EventDrivenPollingConsumer: org.slf4j.Logger LOG>;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.Consumer)>(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[])>("Error occurred before polling \u. This exception will be ignored.");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
protected void afterPoll()
{
org.slf4j.Logger v;
java.lang.Exception v;
org.apache.camel.Consumer v, v, v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
java.lang.String v;
boolean v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
v = v instanceof org.apache.camel.PollingConsumerPollingStrategy;
if v == 0 goto label;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
label:
interfaceinvoke v.<org.apache.camel.PollingConsumerPollingStrategy: void afterPoll()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.camel.impl.EventDrivenPollingConsumer: org.slf4j.Logger LOG>;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.camel.Consumer)>(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[])>("Error occurred after polling \u. This exception will be ignored.");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
protected org.apache.camel.Consumer getConsumer()
{
org.apache.camel.Consumer v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
return v;
}
protected org.apache.camel.Consumer createConsumer() throws java.lang.Exception
{
org.apache.camel.Endpoint v;
org.apache.camel.Consumer v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: org.apache.camel.Consumer createConsumer(org.apache.camel.Processor)>(v);
return v;
}
protected void doStart() throws java.lang.Exception
{
org.apache.camel.impl.EventDrivenPollingConsumer v;
org.apache.camel.Consumer v, v, v, v;
boolean v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = virtualinvoke v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer createConsumer()>();
v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer> = v;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
v = v instanceof org.apache.camel.PollingConsumerPollingStrategy;
if v == 0 goto label;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
interfaceinvoke v.<org.apache.camel.PollingConsumerPollingStrategy: void onInit()>();
goto label;
label:
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
staticinvoke <org.apache.camel.util.ServiceHelper: void startService(org.apache.camel.Service)>(v);
label:
return;
}
protected void doStop() throws java.lang.Exception
{
org.apache.camel.Consumer v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
staticinvoke <org.apache.camel.util.ServiceHelper: void stopService(java.lang.Object)>(v);
return;
}
protected void doShutdown() throws java.lang.Exception
{
java.util.concurrent.BlockingQueue v;
org.apache.camel.Consumer v;
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: org.apache.camel.Consumer consumer>;
staticinvoke <org.apache.camel.util.ServiceHelper: void stopAndShutdownService(java.lang.Object)>(v);
v = v.<org.apache.camel.impl.EventDrivenPollingConsumer: java.util.concurrent.BlockingQueue queue>;
interfaceinvoke v.<java.util.concurrent.BlockingQueue: void clear()>();
return;
}
public boolean isSingleton()
{
org.apache.camel.impl.EventDrivenPollingConsumer v;
v := @this: org.apache.camel.impl.EventDrivenPollingConsumer;
return 1;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/camel/impl/EventDrivenPollingConsumer;");
<org.apache.camel.impl.EventDrivenPollingConsumer: org.slf4j.Logger LOG> = v;
return;
}
}