Interface ManagedAggregateProcessorMBean

All Superinterfaces:

ManagedCounterMBean, ManagedPerformanceCounterMBean, ManagedProcessorMBean

public interface ManagedAggregateProcessorMBean
extends ManagedProcessorMBean

Method Summary

Modifier and Type	Method	Description
int	aggregationRepositoryGroups()
void	clearClosedCorrelationKeysCache()
int	forceCompletionOfAllGroups()
int	forceCompletionOfGroup(String key)
int	forceDiscardingOfAllGroups()
int	forceDiscardingOfGroup(String key)
Integer	getCloseCorrelationKeyOnCompletion()
int	getClosedCorrelationKeysCacheSize()
long	getCompletedByBatchConsumer()
long	getCompletedByForce()
long	getCompletedByInterval()
long	getCompletedByPredicate()
long	getCompletedBySize()
long	getCompletedByStrategy()
long	getCompletedByTimeout()
long	getCompletionInterval()
String	getCompletionPredicate()
String	getCompletionPredicateLanguage()
int	getCompletionSize()
String	getCompletionSizeExpression()
String	getCompletionSizeExpressionLanguage()
long	getCompletionTimeout()
long	getCompletionTimeoutCheckerInterval()
String	getCompletionTimeoutExpression()
String	getCompletionTimeoutLanguage()
String	getCorrelationExpression()
String	getCorrelationExpressionLanguage()
long	getDiscarded()
int	getInProgressCompleteExchanges()
long	getTotalCompleted()
long	getTotalIn()
boolean	isCompleteAllOnStop()
boolean	isCompletionFromBatchConsumer()
boolean	isCompletionOnNewCorrelationGroup()
boolean	isDiscardOnCompletionTimeout()
boolean	isEagerCheckCompletion()
boolean	isForceCompletionOnStop()
boolean	isIgnoreInvalidCorrelationKeys()
boolean	isOptimisticLocking()
boolean	isParallelProcessing()
boolean	isStatisticsEnabled()
void	resetStatistics()
void	setStatisticsEnabled(boolean statisticsEnabled)

Methods inherited from interface ManagedCounterMBean

getExchangesTotal, getResetTimestamp, getStartTimestamp, reset

Methods inherited from interface ManagedPerformanceCounterMBean

dumpStatsAsJSon, dumpStatsAsXml, getDeltaProcessingTime, getExchangesCompleted, getExchangesFailed, getExchangesInflight, getExternalRedeliveries, getFailuresHandled, getFirstExchangeCompletedExchangeId, getFirstExchangeCompletedTimestamp, getFirstExchangeFailureExchangeId, getFirstExchangeFailureTimestamp, getIdleSince, getLastExchangeCompletedExchangeId, getLastExchangeCompletedTimestamp, getLastExchangeCreatedTimestamp, getLastExchangeFailureExchangeId, getLastExchangeFailureTimestamp, getLastProcessingTime, getMaxProcessingTime, getMeanProcessingTime, getMinProcessingTime, getRedeliveries, getTotalProcessingTime, statsAsJSon

Methods inherited from interface ManagedProcessorMBean

disable, dumpProcessorAsXml, enable, getCamelId, getCamelManagementName, getDescription, getDisabled, getIndex, getLevel, getModelLabel, getNodePrefixId, getNote, getProcessorId, getProcessorName, getRouteId, getSourceLineNumber, getSourceLocation, getSourceLocationShort, getState, getStepId, getSupportExtendedInformation, start, stop

Method Details

getCorrelationExpressionLanguage

@ManagedAttribute(description="The language for the expression")
String getCorrelationExpressionLanguage()

getCorrelationExpression

@ManagedAttribute(description="Correlation Expression")
String getCorrelationExpression()

getCompletionTimeout

@ManagedAttribute(description="Completion timeout in millis")
long getCompletionTimeout()

getCompletionTimeoutLanguage

@ManagedAttribute(description="The language for the expression")
String getCompletionTimeoutLanguage()

getCompletionTimeoutExpression

@ManagedAttribute(description="Completion timeout expression")
String getCompletionTimeoutExpression()

getCompletionInterval

@ManagedAttribute(description="Completion interval in millis")
long getCompletionInterval()

getCompletionTimeoutCheckerInterval

@ManagedAttribute(description="Completion timeout checker interval in millis")
long getCompletionTimeoutCheckerInterval()

getCompletionSize

@ManagedAttribute(description="Completion size")
int getCompletionSize()

getCompletionSizeExpressionLanguage

@ManagedAttribute(description="The language for the expression")
String getCompletionSizeExpressionLanguage()

getCompletionSizeExpression

@ManagedAttribute(description="Completion size expression")
String getCompletionSizeExpression()

isCompletionFromBatchConsumer

@ManagedAttribute(description="Complete from batch consumers")
boolean isCompletionFromBatchConsumer()

isCompletionOnNewCorrelationGroup

@ManagedAttribute(description="Complete all previous groups on new incoming correlation group")
boolean isCompletionOnNewCorrelationGroup()

isIgnoreInvalidCorrelationKeys

@ManagedAttribute(description="Ignore invalid correlation keys")
boolean isIgnoreInvalidCorrelationKeys()

getCloseCorrelationKeyOnCompletion

@ManagedAttribute(description="Whether to close the correlation group on completion if this value is > 0.")
Integer getCloseCorrelationKeyOnCompletion()

isParallelProcessing

@ManagedAttribute(description="Parallel mode")
boolean isParallelProcessing()

isOptimisticLocking

@ManagedAttribute(description="Optimistic locking")
boolean isOptimisticLocking()

isEagerCheckCompletion

@ManagedAttribute(description="Whether or not to eager check for completion when a new incoming Exchange has been received")
boolean isEagerCheckCompletion()

getCompletionPredicateLanguage

@ManagedAttribute(description="The language for the predicate")
String getCompletionPredicateLanguage()

getCompletionPredicate

@ManagedAttribute(description="A Predicate to indicate when an aggregated exchange is complete")
String getCompletionPredicate()

isDiscardOnCompletionTimeout

@ManagedAttribute(description="Whether or not exchanges which complete due to a timeout should be discarded")
boolean isDiscardOnCompletionTimeout()

isForceCompletionOnStop

@ManagedAttribute(description="Indicates to complete all current aggregated exchanges when the context is stopped")
boolean isForceCompletionOnStop()

isCompleteAllOnStop

@ManagedAttribute(description="Indicates to wait to complete all current and partial (pending) aggregated exchanges when the context is stopped")
boolean isCompleteAllOnStop()

getInProgressCompleteExchanges

@ManagedAttribute(description="Number of completed exchanges which are currently in-flight")
int getInProgressCompleteExchanges()

aggregationRepositoryGroups

@ManagedOperation(description="Number of groups currently in the aggregation repository")
int aggregationRepositoryGroups()

forceCompletionOfGroup

@ManagedOperation(description="To force completing a specific group by its key")
int forceCompletionOfGroup(String key)

forceCompletionOfAllGroups

@ManagedOperation(description="To force complete of all groups")
int forceCompletionOfAllGroups()

forceDiscardingOfGroup

@ManagedOperation(description="To force discarding a specific group by its key")
int forceDiscardingOfGroup(String key)

forceDiscardingOfAllGroups

@ManagedOperation(description="To force discarding of all groups")
int forceDiscardingOfAllGroups()

getClosedCorrelationKeysCacheSize

@ManagedAttribute(description="Current number of closed correlation keys in the memory cache")
int getClosedCorrelationKeysCacheSize()

clearClosedCorrelationKeysCache

@ManagedOperation(description="Clear all the closed correlation keys stored in the cache")
void clearClosedCorrelationKeysCache()

getTotalIn

@ManagedAttribute(description="Total number of exchanges arrived into the aggregator")
long getTotalIn()

getTotalCompleted

@ManagedAttribute(description="Total number of exchanges completed and outgoing from the aggregator")
long getTotalCompleted()

getCompletedBySize

@ManagedAttribute(description="Total number of exchanged completed by completion size trigger")
long getCompletedBySize()

getCompletedByStrategy

@ManagedAttribute(description="Total number of exchanged completed by completion aggregation strategy trigger")
long getCompletedByStrategy()

getCompletedByInterval

@ManagedAttribute(description="Total number of exchanged completed by completion interval (timeout) trigger")
long getCompletedByInterval()

getCompletedByTimeout

@ManagedAttribute(description="Total number of exchanged completed by completion timeout trigger")
long getCompletedByTimeout()

getCompletedByPredicate

@ManagedAttribute(description="Total number of exchanged completed by completion predicate trigger")
long getCompletedByPredicate()

getCompletedByBatchConsumer

@ManagedAttribute(description="Total number of exchanged completed by completion batch consumer trigger")
long getCompletedByBatchConsumer()

getCompletedByForce

@ManagedAttribute(description="Total number of exchanged completed by completion force trigger")
long getCompletedByForce()

getDiscarded

@ManagedAttribute(description="Total number of exchanged discarded")
long getDiscarded()

resetStatistics

@ManagedOperation(description=" Reset the statistics counters")
void resetStatistics()

isStatisticsEnabled

@ManagedAttribute(description="Sets whether statistics is enabled")
boolean isStatisticsEnabled()

Specified by:

isStatisticsEnabled in interface ManagedPerformanceCounterMBean

setStatisticsEnabled

@ManagedAttribute(description="Sets whether statistics is enabled")
void setStatisticsEnabled(boolean statisticsEnabled)

Specified by:

setStatisticsEnabled in interface ManagedPerformanceCounterMBean