Package org.apache.camel.management.mbean

Class ManagedThreads

java.lang.Object

org.apache.camel.management.mbean.ManagedCounter

org.apache.camel.management.mbean.ManagedPerformanceCounter

org.apache.camel.management.mbean.ManagedProcessor

org.apache.camel.management.mbean.ManagedThreads

All Implemented Interfaces:

org.apache.camel.api.management.ManagedInstance, org.apache.camel.api.management.mbean.ManagedCounterMBean, org.apache.camel.api.management.mbean.ManagedPerformanceCounterMBean, org.apache.camel.api.management.mbean.ManagedProcessorAware, org.apache.camel.api.management.mbean.ManagedProcessorMBean, org.apache.camel.api.management.mbean.ManagedThreadsMBean, PerformanceCounter

@ManagedResource(description="Managed Threads")
public class ManagedThreads
extends ManagedProcessor
implements org.apache.camel.api.management.mbean.ManagedThreadsMBean

Field Summary

Fields inherited from class org.apache.camel.management.mbean.ManagedPerformanceCounter

TIMESTAMP_FORMAT

Fields inherited from class org.apache.camel.management.mbean.ManagedCounter

exchangesTotal, resetTimestamp, startTimestamp

Constructor Summary

Constructors

Constructor	Description
ManagedThreads(org.apache.camel.CamelContext context, org.apache.camel.processor.ThreadsProcessor processor, org.apache.camel.model.ProcessorDefinition<?> definition)

Method Summary

Modifier and Type	Method	Description
int	getActiveCount()
long	getCompletedTaskCount()
int	getCorePoolSize()
long	getKeepAliveTime()
int	getLargestPoolSize()
int	getMaximumPoolSize()
int	getPoolSize()
org.apache.camel.processor.ThreadsProcessor	getProcessor()
String	getRejectedPolicy()
long	getTaskCount()
long	getTaskQueueSize()
boolean	isAllowCoreThreadTimeout()
Boolean	isCallerRunsWhenRejected()

Methods inherited from class org.apache.camel.management.mbean.ManagedProcessor

disable, dumpProcessorAsXml, enable, getCamelId, getCamelManagementName, getContext, getDefinition, getDescription, getDisabled, getId, getIndex, getInstance, getLevel, getModelLabel, getNodePrefixId, getNote, getProcessorId, getProcessorName, getRoute, getRouteId, getSourceLineNumber, getSourceLocation, getSourceLocationShort, getState, getStepId, getSupportExtendedInformation, init, setProcessor, setRoute, start, stop

Methods inherited from class org.apache.camel.management.mbean.ManagedPerformanceCounter

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

Methods inherited from class org.apache.camel.management.mbean.ManagedCounter

getExchangesTotal, getResetTimestamp, getStartTimestamp, increment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.camel.api.management.mbean.ManagedCounterMBean

getExchangesTotal, getResetTimestamp, getStartTimestamp, reset

Methods inherited from interface org.apache.camel.api.management.mbean.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, isStatisticsEnabled, setStatisticsEnabled, statsAsJSon

Methods inherited from interface org.apache.camel.api.management.mbean.ManagedProcessorMBean

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

Constructor Details

ManagedThreads

public ManagedThreads(org.apache.camel.CamelContext context,
 org.apache.camel.processor.ThreadsProcessor processor,
 org.apache.camel.model.ProcessorDefinition<?> definition)

Method Details

getProcessor

public org.apache.camel.processor.ThreadsProcessor getProcessor()

Specified by:

getProcessor in interface org.apache.camel.api.management.mbean.ManagedProcessorAware

Overrides:

getProcessor in class ManagedProcessor

isCallerRunsWhenRejected

public Boolean isCallerRunsWhenRejected()

Specified by:

isCallerRunsWhenRejected in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getRejectedPolicy

public String getRejectedPolicy()

Specified by:

getRejectedPolicy in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getCorePoolSize

public int getCorePoolSize()

Specified by:

getCorePoolSize in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getPoolSize

public int getPoolSize()

Specified by:

getPoolSize in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getMaximumPoolSize

public int getMaximumPoolSize()

Specified by:

getMaximumPoolSize in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getLargestPoolSize

public int getLargestPoolSize()

Specified by:

getLargestPoolSize in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getTaskCount

public long getTaskCount()

Specified by:

getTaskCount in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getCompletedTaskCount

public long getCompletedTaskCount()

Specified by:

getCompletedTaskCount in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getTaskQueueSize

public long getTaskQueueSize()

Specified by:

getTaskQueueSize in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

getKeepAliveTime

public long getKeepAliveTime()

Specified by:

getKeepAliveTime in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean

isAllowCoreThreadTimeout

public boolean isAllowCoreThreadTimeout()

Specified by:

isAllowCoreThreadTimeout in interface org.apache.camel.api.management.mbean.ManagedThreadsMBean