@ManagedResource(description="Managed Throttler") public class ManagedThrottler extends ManagedProcessor implements ManagedThrottlerMBean
TIMESTAMP_FORMATexchangesTotal, resetTimestamp, startTimestamp| Constructor and Description |
|---|
ManagedThrottler(CamelContext context,
Throttler throttler,
ProcessorDefinition<?> definition) |
| Modifier and Type | Method and Description |
|---|---|
long |
getMaximumRequestsPerPeriod() |
Throttler |
getThrottler() |
long |
getTimePeriodMillis() |
Boolean |
isAsyncDelayed() |
Boolean |
isCallerRunsWhenRejected() |
Boolean |
isRejectExecution() |
void |
setMaximumRequestsPerPeriod(long maximumRequestsPerPeriod) |
void |
setTimePeriodMillis(long timePeriodMillis) |
dumpProcessorAsXml, explain, getCamelId, getCamelManagementName, getContext, getDefinition, getId, getIndex, getInstance, getProcessor, getProcessorId, getRoute, getRouteId, getState, getSupportExtendedInformation, informationJson, init, 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, waitdumpProcessorAsXml, 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, getTotalProcessingTime, isStatisticsEnabled, setStatisticsEnabledgetExchangesTotal, getResetTimestamp, getStartTimestamp, resetpublic ManagedThrottler(CamelContext context, Throttler throttler, ProcessorDefinition<?> definition)
public Throttler getThrottler()
public long getMaximumRequestsPerPeriod()
getMaximumRequestsPerPeriod in interface ManagedThrottlerMBeanpublic void setMaximumRequestsPerPeriod(long maximumRequestsPerPeriod)
setMaximumRequestsPerPeriod in interface ManagedThrottlerMBeanpublic long getTimePeriodMillis()
getTimePeriodMillis in interface ManagedThrottlerMBeanpublic void setTimePeriodMillis(long timePeriodMillis)
setTimePeriodMillis in interface ManagedThrottlerMBeanpublic Boolean isAsyncDelayed()
isAsyncDelayed in interface ManagedThrottlerMBeanpublic Boolean isCallerRunsWhenRejected()
isCallerRunsWhenRejected in interface ManagedThrottlerMBeanpublic Boolean isRejectExecution()
isRejectExecution in interface ManagedThrottlerMBeanApache Camel