Java 类org.apache.camel.api.management.ManagedAttribute 实例源码

@ManagedAttribute
public long getHystrixTotalRequests() {
    HystrixCommandMetrics metrics = HystrixCommandMetrics.getInstance(commandKey);
    if (metrics != null) {
        return metrics.getHealthCounts().getTotalRequests();
    }
    return 0;
}

@ManagedAttribute
public String getReplyToType() {
    if (configuration.getReplyToType() != null) {
        return configuration.getReplyToType().name();
    } else {
        return null;
    }
}

@ManagedAttribute
public int getHystrixExecutionTimeMean() {
    HystrixCommandMetrics metrics = HystrixCommandMetrics.getInstance(commandKey);
    if (metrics != null) {
        return metrics.getExecutionTimeMean();
    }
    return 0;
}

@ManagedAttribute(description = "Delegate Endpoint URI", mask = true)
public String getDelegateEndpointUri() {
    return endpoint.getEndpointUri();
}

@ManagedAttribute
public String getReplyToOverride() {
    return getConfiguration().getReplyToOverride();
}

@ManagedAttribute(description = "Logging Level")
String getLogLevel();

@ManagedAttribute(description = "Logging Name")
void setLogName(String logName);

/**
 * @return the API key for the ExLibris ALMA environment.
 */
@ManagedAttribute(description = "API key to use for authentication with ExLibris ALMA")
public String getApiKey() {
    return this.apiKey;
}

@ManagedAttribute(description = "Queue name")
public String getName() {
    return name;
}

/**
 * Set the API operation to use for this endpoint.
 * @param operation the ALMA api operation to use.
 */
@ManagedAttribute(description = "API operation to use with this ExLibris ALMA endpoint")
public void setOperation(String operation) {
    this.operation = operation;

}

@ManagedAttribute
public Integer getCount() {
    return getProperties().getCount();
}

@ManagedAttribute(description = "Defines the strategy used by consumer threads to wait on new exchanges to be published")
public DisruptorWaitStrategy getWaitStrategy() {
    return waitStrategy;
}

@ManagedAttribute
public boolean isAcceptMessagesWhileStopping() {
    return getConfiguration().isAcceptMessagesWhileStopping();
}

@ManagedAttribute(description = "RedeliveryPolicy for logging level when retries exhausted")
String getRetriesExhaustedLogLevel();

@ManagedAttribute(description = "Whether to aggregate when there was an exception thrown during calling the resource endpoint")
Boolean isAggregateOnException();

@ManagedAttribute
public void setRecoveryInterval(long recoveryInterval) {
    getConfiguration().setRecoveryInterval(recoveryInterval);
}

@ManagedAttribute(description = "Whether this service supports suspension")
boolean isSupportSuspension();

@ManagedAttribute(description = "EventNotifier enabled")
Boolean isEventNotifierEnabled();

@ManagedAttribute(description = "ID of source for creating Thread Pool")
String getSourceId();

@ManagedAttribute
public long getSinceId() {
    return getProperties().getSinceId();
}

@ManagedAttribute(description = "Number of threads that are blocked waiting for other threads to trigger the callback when they are done processing the exchange")
int getSize();

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

@ManagedAttribute(description = "RedeliveryPolicy for redelivery delay")
Long getRedeliveryDelay();

@ManagedAttribute(description = "Expression to use for re-ordering the messages, such as a header with a sequence number")
String getExpression();

@ManagedAttribute(description = "Whether to use Saxon as the transformerFactoryClass")
public boolean isSaxon() {
    return saxon;
}

@ManagedAttribute(description = "Trace Exceptions")
void setTraceExceptions(boolean traceExceptions);

@ManagedAttribute(description = "Average load over the last fifteen minutes")
String getLoad15();

@ManagedAttribute(description = "Whether the resource is cached")
public boolean isContentCache() {
    return contentCache;
}

@ManagedAttribute(description = "PackageScanClassResolver class name")
String getPackageScanClassResolver();

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

@ManagedAttribute(description = "Number of total endpoints cached")
Integer getSize();

@ManagedAttribute(description = "Whether to force shutdown now when a timeout occurred")
boolean isShutdownNowOnTimeout();

@ManagedAttribute(description = "Timer FixedRate")
public boolean isFixedRate() {
    return fixedRate;
}

@ManagedAttribute
public void setReplyToCacheLevelName(String cacheName) {
    getConfiguration().setReplyToCacheLevelName(cacheName);
}

@ManagedAttribute
public void setRequestTimeout(long requestTimeout) {
    getConfiguration().setRequestTimeout(requestTimeout);
}

@ManagedAttribute(description = "Logging Level")
void setLogLevel(String logLevel);

@ManagedAttribute
public void setFoo(String foo) {
    this.foo = foo;
}

@ManagedAttribute(description = "Utilization statistics enabled")
void setStatisticsEnabled(boolean statisticsEnabled);

@ManagedAttribute(description = "The delimiter")
String getDistributionRatioDelimiter();

@ManagedAttribute
public void setAutoStartup(boolean autoStartup) {
    getConfiguration().setAutoStartup(autoStartup);
}