@ManagedResource(description="Managed AggregateProcessor") public class ManagedAggregateProcessor extends ManagedProcessor implements ManagedAggregateProcessorMBean
TIMESTAMP_FORMATexchangesTotal, resetTimestamp, startTimestamp| Constructor and Description |
|---|
ManagedAggregateProcessor(CamelContext context,
AggregateProcessor processor,
AggregateDefinition definition) |
dumpProcessorAsXml, explain, getCamelId, getCamelManagementName, getContext, getId, getIndex, getInstance, getProcessorId, getRoute, getRouteId, getState, getSupportExtendedInformation, informationJson, setRoute, start, stopcompletedExchange, dumpStatsAsXml, failedExchange, getDeltaProcessingTime, getExchangesCompleted, getExchangesFailed, getExchangesInflight, getExternalRedeliveries, getFailuresHandled, getFirstExchangeCompletedExchangeId, getFirstExchangeCompletedTimestamp, getFirstExchangeFailureExchangeId, getFirstExchangeFailureTimestamp, getLastExchangeCompletedExchangeId, getLastExchangeCompletedTimestamp, getLastExchangeFailureExchangeId, getLastExchangeFailureTimestamp, getLastProcessingTime, getMaxProcessingTime, getMeanProcessingTime, getMinProcessingTime, getRedeliveries, getTotalProcessingTime, isStatisticsEnabled, processExchange, reset, setStatisticsEnabledgetExchangesTotal, getResetTimestamp, getStartTimestamp, incrementclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisStatisticsEnabled, setStatisticsEnableddumpProcessorAsXml, explain, getCamelId, getCamelManagementName, getIndex, getProcessorId, getRouteId, getState, getSupportExtendedInformation, informationJson, start, stopdumpStatsAsXml, getDeltaProcessingTime, getExchangesCompleted, getExchangesFailed, getExchangesInflight, getExternalRedeliveries, getFailuresHandled, getFirstExchangeCompletedExchangeId, getFirstExchangeCompletedTimestamp, getFirstExchangeFailureExchangeId, getFirstExchangeFailureTimestamp, getLastExchangeCompletedExchangeId, getLastExchangeCompletedTimestamp, getLastExchangeFailureExchangeId, getLastExchangeFailureTimestamp, getLastProcessingTime, getMaxProcessingTime, getMeanProcessingTime, getMinProcessingTime, getRedeliveries, getTotalProcessingTimegetExchangesTotal, getResetTimestamp, getStartTimestamp, resetpublic ManagedAggregateProcessor(CamelContext context, AggregateProcessor processor, AggregateDefinition definition)
public void init(ManagementStrategy strategy)
init in class ManagedProcessorpublic AggregateProcessor getProcessor()
getProcessor in class ManagedProcessorpublic AggregateDefinition getDefinition()
getDefinition in class ManagedProcessorpublic String getCorrelationExpressionLanguage()
getCorrelationExpressionLanguage in interface ManagedAggregateProcessorMBeanpublic String getCorrelationExpression()
getCorrelationExpression in interface ManagedAggregateProcessorMBeanpublic long getCompletionTimeout()
getCompletionTimeout in interface ManagedAggregateProcessorMBeanpublic String getCompletionTimeoutLanguage()
getCompletionTimeoutLanguage in interface ManagedAggregateProcessorMBeanpublic String getCompletionTimeoutExpression()
getCompletionTimeoutExpression in interface ManagedAggregateProcessorMBeanpublic long getCompletionInterval()
getCompletionInterval in interface ManagedAggregateProcessorMBeanpublic long getCompletionTimeoutCheckerInterval()
getCompletionTimeoutCheckerInterval in interface ManagedAggregateProcessorMBeanpublic int getCompletionSize()
getCompletionSize in interface ManagedAggregateProcessorMBeanpublic String getCompletionSizeExpressionLanguage()
getCompletionSizeExpressionLanguage in interface ManagedAggregateProcessorMBeanpublic String getCompletionSizeExpression()
getCompletionSizeExpression in interface ManagedAggregateProcessorMBeanpublic boolean isCompletionFromBatchConsumer()
isCompletionFromBatchConsumer in interface ManagedAggregateProcessorMBeanpublic boolean isCompletionOnNewCorrelationGroup()
isCompletionOnNewCorrelationGroup in interface ManagedAggregateProcessorMBeanpublic boolean isIgnoreInvalidCorrelationKeys()
isIgnoreInvalidCorrelationKeys in interface ManagedAggregateProcessorMBeanpublic Integer getCloseCorrelationKeyOnCompletion()
getCloseCorrelationKeyOnCompletion in interface ManagedAggregateProcessorMBeanpublic boolean isParallelProcessing()
isParallelProcessing in interface ManagedAggregateProcessorMBeanpublic boolean isOptimisticLocking()
isOptimisticLocking in interface ManagedAggregateProcessorMBeanpublic boolean isEagerCheckCompletion()
isEagerCheckCompletion in interface ManagedAggregateProcessorMBeanpublic String getCompletionPredicateLanguage()
getCompletionPredicateLanguage in interface ManagedAggregateProcessorMBeanpublic String getCompletionPredicate()
getCompletionPredicate in interface ManagedAggregateProcessorMBeanpublic boolean isDiscardOnCompletionTimeout()
isDiscardOnCompletionTimeout in interface ManagedAggregateProcessorMBeanpublic boolean isForceCompletionOnStop()
isForceCompletionOnStop in interface ManagedAggregateProcessorMBeanpublic boolean isCompleteAllOnStop()
isCompleteAllOnStop in interface ManagedAggregateProcessorMBeanpublic int getInProgressCompleteExchanges()
getInProgressCompleteExchanges in interface ManagedAggregateProcessorMBeanpublic int aggregationRepositoryGroups()
aggregationRepositoryGroups in interface ManagedAggregateProcessorMBeanpublic int forceCompletionOfGroup(String key)
forceCompletionOfGroup in interface ManagedAggregateProcessorMBeanpublic int forceCompletionOfAllGroups()
forceCompletionOfAllGroups in interface ManagedAggregateProcessorMBeanpublic int getClosedCorrelationKeysCacheSize()
getClosedCorrelationKeysCacheSize in interface ManagedAggregateProcessorMBeanpublic void clearClosedCorrelationKeysCache()
clearClosedCorrelationKeysCache in interface ManagedAggregateProcessorMBeanpublic long getTotalIn()
getTotalIn in interface ManagedAggregateProcessorMBeanpublic long getTotalCompleted()
getTotalCompleted in interface ManagedAggregateProcessorMBeanpublic long getCompletedBySize()
getCompletedBySize in interface ManagedAggregateProcessorMBeanpublic long getCompletedByStrategy()
getCompletedByStrategy in interface ManagedAggregateProcessorMBeanpublic long getCompletedByInterval()
getCompletedByInterval in interface ManagedAggregateProcessorMBeanpublic long getCompletedByTimeout()
getCompletedByTimeout in interface ManagedAggregateProcessorMBeanpublic long getCompletedByPredicate()
getCompletedByPredicate in interface ManagedAggregateProcessorMBeanpublic long getCompletedByBatchConsumer()
getCompletedByBatchConsumer in interface ManagedAggregateProcessorMBeanpublic long getCompletedByForce()
getCompletedByForce in interface ManagedAggregateProcessorMBeanpublic void resetStatistics()
resetStatistics in interface ManagedAggregateProcessorMBeanApache Camel