public class org.apache.camel.management.mbean.ManagedAggregateProcessor extends org.apache.camel.management.mbean.ManagedProcessor implements org.apache.camel.api.management.mbean.ManagedAggregateProcessorMBean
{
private final org.apache.camel.processor.aggregate.AggregateProcessor processor;
public void <init>(org.apache.camel.CamelContext, org.apache.camel.processor.aggregate.AggregateProcessor, org.apache.camel.model.AggregateDefinition)
{
org.apache.camel.CamelContext v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
org.apache.camel.model.AggregateDefinition v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: org.apache.camel.processor.aggregate.AggregateProcessor;
v := @parameter: org.apache.camel.model.AggregateDefinition;
specialinvoke v.<org.apache.camel.management.mbean.ManagedProcessor: void <init>(org.apache.camel.CamelContext,org.apache.camel.Processor,org.apache.camel.model.ProcessorDefinition)>(v, v, v);
v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor> = v;
return;
}
public void init(org.apache.camel.spi.ManagementStrategy)
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.spi.ManagementStrategy v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v := @parameter: org.apache.camel.spi.ManagementStrategy;
specialinvoke v.<org.apache.camel.management.mbean.ManagedProcessor: void init(org.apache.camel.spi.ManagementStrategy)>(v);
return;
}
public org.apache.camel.processor.aggregate.AggregateProcessor getProcessor()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
return v;
}
public org.apache.camel.model.AggregateDefinition getDefinition()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.ProcessorDefinition v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = specialinvoke v.<org.apache.camel.management.mbean.ManagedProcessor: org.apache.camel.model.ProcessorDefinition getDefinition()>();
return v;
}
public java.lang.String getCorrelationExpressionLanguage()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCorrelationExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCorrelationExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getLanguage()>();
return v;
label:
return null;
}
public java.lang.String getCorrelationExpression()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCorrelationExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCorrelationExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getExpression()>();
return v;
label:
return null;
}
public long getCompletionTimeout()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: long getCompletionTimeout()>();
return v;
}
public java.lang.String getCompletionTimeoutLanguage()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionTimeoutExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionTimeoutExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getLanguage()>();
return v;
label:
return null;
}
public java.lang.String getCompletionTimeoutExpression()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionTimeoutExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionTimeoutExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getExpression()>();
return v;
label:
return null;
}
public long getCompletionInterval()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: long getCompletionInterval()>();
return v;
}
public long getCompletionTimeoutCheckerInterval()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: long getCompletionTimeoutCheckerInterval()>();
return v;
}
public int getCompletionSize()
{
int v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: int getCompletionSize()>();
return v;
}
public java.lang.String getCompletionSizeExpressionLanguage()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionSizeExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionSizeExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getLanguage()>();
return v;
label:
return null;
}
public java.lang.String getCompletionSizeExpression()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionSizeExpression()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionSizeExpression()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getExpression()>();
return v;
label:
return null;
}
public boolean isCompletionFromBatchConsumer()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isCompletionFromBatchConsumer()>();
return v;
}
public boolean isCompletionOnNewCorrelationGroup()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isCompletionOnNewCorrelationGroup()>();
return v;
}
public boolean isIgnoreInvalidCorrelationKeys()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isIgnoreInvalidCorrelationKeys()>();
return v;
}
public java.lang.Integer getCloseCorrelationKeyOnCompletion()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
java.lang.Integer v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: java.lang.Integer getCloseCorrelationKeyOnCompletion()>();
return v;
}
public boolean isParallelProcessing()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isParallelProcessing()>();
return v;
}
public boolean isOptimisticLocking()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isOptimisticLocking()>();
return v;
}
public boolean isEagerCheckCompletion()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isEagerCheckCompletion()>();
return v;
}
public java.lang.String getCompletionPredicateLanguage()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionPredicate()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionPredicate()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getLanguage()>();
return v;
label:
return null;
}
public java.lang.String getCompletionPredicate()
{
org.apache.camel.model.ExpressionSubElementDefinition v, v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.model.language.ExpressionDefinition v;
java.lang.String v;
org.apache.camel.model.AggregateDefinition v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionPredicate()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.model.AggregateDefinition getDefinition()>();
v = virtualinvoke v.<org.apache.camel.model.AggregateDefinition: org.apache.camel.model.ExpressionSubElementDefinition getCompletionPredicate()>();
v = virtualinvoke v.<org.apache.camel.model.ExpressionSubElementDefinition: org.apache.camel.model.language.ExpressionDefinition getExpressionType()>();
v = virtualinvoke v.<org.apache.camel.model.language.ExpressionDefinition: java.lang.String getExpression()>();
return v;
label:
return null;
}
public boolean isDiscardOnCompletionTimeout()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isDiscardOnCompletionTimeout()>();
return v;
}
public boolean isForceCompletionOnStop()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isCompletionFromBatchConsumer()>();
return v;
}
public boolean isCompleteAllOnStop()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
boolean v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: boolean isCompleteAllOnStop()>();
return v;
}
public int getInProgressCompleteExchanges()
{
int v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: int getInProgressCompleteExchanges()>();
return v;
}
public int aggregationRepositoryGroups()
{
org.apache.camel.spi.AggregationRepository v;
int v;
java.util.Set v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.spi.AggregationRepository getAggregationRepository()>();
v = interfaceinvoke v.<org.apache.camel.spi.AggregationRepository: java.util.Set getKeys()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Set: int size()>();
return v;
label:
return 0;
}
public int forceCompletionOfGroup(java.lang.String)
{
int v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
java.lang.String v;
org.apache.camel.processor.aggregate.AggregateController v, v;
org.apache.camel.processor.aggregate.AggregateProcessor v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v := @parameter: java.lang.String;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateController getAggregateController()>();
if v == null goto label;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateController getAggregateController()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateController: int forceCompletionOfGroup(java.lang.String)>(v);
return v;
label:
return 0;
}
public int forceCompletionOfAllGroups()
{
int v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateController v, v;
org.apache.camel.processor.aggregate.AggregateProcessor v, v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateController getAggregateController()>();
if v == null goto label;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateController getAggregateController()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateController: int forceCompletionOfAllGroups()>();
return v;
label:
return 0;
}
public int getClosedCorrelationKeysCacheSize()
{
int v;
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: int getClosedCorrelationKeysCacheSize()>();
return v;
}
public void clearClosedCorrelationKeysCache()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: void clearClosedCorrelationKeysCache()>();
return;
}
public long getTotalIn()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getTotalIn()>();
return v;
}
public long getTotalCompleted()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getTotalCompleted()>();
return v;
}
public long getCompletedBySize()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedBySize()>();
return v;
}
public long getCompletedByStrategy()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByStrategy()>();
return v;
}
public long getCompletedByInterval()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByInterval()>();
return v;
}
public long getCompletedByTimeout()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByTimeout()>();
return v;
}
public long getCompletedByPredicate()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByPredicate()>();
return v;
}
public long getCompletedByBatchConsumer()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByBatchConsumer()>();
return v;
}
public long getCompletedByForce()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
long v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
v = interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: long getCompletedByForce()>();
return v;
}
public void resetStatistics()
{
org.apache.camel.management.mbean.ManagedAggregateProcessor v;
org.apache.camel.processor.aggregate.AggregateProcessorStatistics v;
org.apache.camel.processor.aggregate.AggregateProcessor v;
v := @this: org.apache.camel.management.mbean.ManagedAggregateProcessor;
v = v.<org.apache.camel.management.mbean.ManagedAggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessor processor>;
v = virtualinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessor: org.apache.camel.processor.aggregate.AggregateProcessorStatistics getStatistics()>();
interfaceinvoke v.<org.apache.camel.processor.aggregate.AggregateProcessorStatistics: void reset()>();
return;
}
}