@ManagedResource(description="Managed Idempotent Consumer") public class ManagedIdempotentConsumer extends ManagedProcessor implements ManagedIdempotentConsumerMBean
TIMESTAMP_FORMATexchangesTotal, resetTimestamp, startTimestamp| Constructor and Description |
|---|
ManagedIdempotentConsumer(CamelContext context,
IdempotentConsumer idempotentConsumer,
IdempotentConsumerDefinition definition) |
| Modifier and Type | Method and Description |
|---|---|
void |
clear() |
IdempotentConsumerDefinition |
getDefinition() |
long |
getDuplicateMessageCount() |
String |
getExpression() |
String |
getExpressionLanguage() |
IdempotentConsumer |
getProcessor() |
Boolean |
isCompletionEager() |
Boolean |
isEager() |
Boolean |
isRemoveOnFailure() |
Boolean |
isSkipDuplicate() |
void |
resetDuplicateMessageCount() |
dumpProcessorAsXml, explain, getCamelId, getCamelManagementName, getContext, getId, getIndex, getInstance, 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 ManagedIdempotentConsumer(CamelContext context, IdempotentConsumer idempotentConsumer, IdempotentConsumerDefinition definition)
public IdempotentConsumerDefinition getDefinition()
getDefinition in class ManagedProcessorpublic String getExpressionLanguage()
getExpressionLanguage in interface ManagedIdempotentConsumerMBeanpublic String getExpression()
getExpression in interface ManagedIdempotentConsumerMBeanpublic IdempotentConsumer getProcessor()
getProcessor in class ManagedProcessorpublic Boolean isEager()
isEager in interface ManagedIdempotentConsumerMBeanpublic Boolean isCompletionEager()
isCompletionEager in interface ManagedIdempotentConsumerMBeanpublic Boolean isSkipDuplicate()
isSkipDuplicate in interface ManagedIdempotentConsumerMBeanpublic Boolean isRemoveOnFailure()
isRemoveOnFailure in interface ManagedIdempotentConsumerMBeanpublic long getDuplicateMessageCount()
getDuplicateMessageCount in interface ManagedIdempotentConsumerMBeanpublic void resetDuplicateMessageCount()
resetDuplicateMessageCount in interface ManagedIdempotentConsumerMBeanpublic void clear()
clear in interface ManagedIdempotentConsumerMBeanApache Camel