本文整理汇总了Java中org.apache.camel.spi.ManagementStrategy类的典型用法代码示例。如果您正苦于以下问题：Java ManagementStrategy类的具体用法？Java ManagementStrategy怎么用？Java ManagementStrategy使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ManagementStrategy类属于org.apache.camel.spi包，在下文中一共展示了ManagementStrategy类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: create
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public ManagementStrategy create(CamelContext context, boolean disableJMX) {
ManagementStrategy answer;
if (disableJMX || Boolean.getBoolean(JmxSystemPropertyKeys.DISABLED)) {
answer = new DefaultManagementStrategy(context);
} else {
try {
answer = new ManagedManagementStrategy(context, new DefaultManagementAgent(context));
// must add management lifecycle strategy
context.getLifecycleStrategies().add(0, new DefaultManagementLifecycleStrategy(context));
} catch (Exception e) {
log.warn("Cannot create JMX lifecycle strategy. Will fallback and disable JMX.", e);
answer = new DefaultManagementStrategy(context);
}
}
return answer;
}
开发者ID:HydAu，项目名称:Camel，代码行数:20，代码来源:ManagementStrategyFactory.java
示例2: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
super.init(strategy);
this.exchangesCompleted = new Statistic("org.apache.camel.exchangesCompleted", this, Statistic.UpdateMode.COUNTER);
this.exchangesFailed = new Statistic("org.apache.camel.exchangesFailed", this, Statistic.UpdateMode.COUNTER);
this.exchangesInflight = new Statistic("org.apache.camel.exchangesInflight", this, Statistic.UpdateMode.COUNTER);
this.failuresHandled = new Statistic("org.apache.camel.failuresHandled", this, Statistic.UpdateMode.COUNTER);
this.redeliveries = new Statistic("org.apache.camel.redeliveries", this, Statistic.UpdateMode.COUNTER);
this.externalRedeliveries = new Statistic("org.apache.camel.externalRedeliveries", this, Statistic.UpdateMode.COUNTER);
this.minProcessingTime = new Statistic("org.apache.camel.minimumProcessingTime", this, Statistic.UpdateMode.MINIMUM);
this.maxProcessingTime = new Statistic("org.apache.camel.maximumProcessingTime", this, Statistic.UpdateMode.MAXIMUM);
this.totalProcessingTime = new Statistic("org.apache.camel.totalProcessingTime", this, Statistic.UpdateMode.COUNTER);
this.lastProcessingTime = new Statistic("org.apache.camel.lastProcessingTime", this, Statistic.UpdateMode.VALUE);
this.deltaProcessingTime = new Statistic("org.apache.camel.deltaProcessingTime", this, Statistic.UpdateMode.DELTA);
this.meanProcessingTime = new Statistic("org.apache.camel.meanProcessingTime", this, Statistic.UpdateMode.VALUE);
this.firstExchangeCompletedTimestamp = new Statistic("org.apache.camel.firstExchangeCompletedTimestamp", this, Statistic.UpdateMode.VALUE);
this.firstExchangeFailureTimestamp = new Statistic("org.apache.camel.firstExchangeFailureTimestamp", this, Statistic.UpdateMode.VALUE);
this.lastExchangeCompletedTimestamp = new Statistic("org.apache.camel.lastExchangeCompletedTimestamp", this, Statistic.UpdateMode.VALUE);
this.lastExchangeFailureTimestamp = new Statistic("org.apache.camel.lastExchangeFailureTimestamp", this, Statistic.UpdateMode.VALUE);
}
开发者ID:HydAu，项目名称:Camel，代码行数:23，代码来源:ManagedPerformanceCounter.java
示例3: createCamelContext
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
protected CamelContext createCamelContext() throws Exception {
CamelContext camelContext = super.createCamelContext();
ShutdownStrategy shutdownStrategy = camelContext.getShutdownStrategy();
camelContext.addComponent("async", new MyAsyncComponent());
shutdownStrategy.setTimeout(1000);
shutdownStrategy.setTimeUnit(TimeUnit.MILLISECONDS);
shutdownStrategy.setShutdownNowOnTimeout(true);
ManagementStrategy managementStrategy = new DefaultManagementStrategy();
managementStrategy.addEventNotifier(en);
camelContext.setManagementStrategy(managementStrategy);
return camelContext;
}
开发者ID:HydAu，项目名称:Camel，代码行数:17，代码来源:EnricherSendEventTest.java
示例4: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
this.exchangesTotal = new Statistic("org.apache.camel.exchangesTotal", this, Statistic.UpdateMode.COUNTER);
this.startTimestamp = new Statistic("org.apache.camel.startTimestamp", this, Statistic.UpdateMode.VALUE);
this.resetTimestamp = new Statistic("org.apache.camel.resetTimestamp", this, Statistic.UpdateMode.VALUE);
startTimestamp.updateValue(new Date().getTime());
resetTimestamp.updateValue(new Date().getTime());
}
开发者ID:HydAu，项目名称:Camel，代码行数:8，代码来源:ManagedCounter.java
示例5: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
@Override
public void init(ManagementStrategy strategy) {
super.init(strategy);
sanitize = strategy.getManagementAgent().getMask() != null ? strategy.getManagementAgent().getMask() : false;
uri = getDefinition().getExpression().getExpression();
if (sanitize) {
uri = URISupport.sanitizeUri(uri);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:10，代码来源:ManagedRecipientList.java
示例6: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
super.init(strategy);
boolean sanitize = strategy.getManagementAgent().getMask() != null ? strategy.getManagementAgent().getMask() : false;
if (sanitize) {
destination = URISupport.sanitizeUri(processor.getDestination().getEndpointUri());
} else {
destination = processor.getDestination().getEndpointUri();
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:10，代码来源:ManagedSendProcessor.java
示例7: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
super.init(strategy);
sanitize = strategy.getManagementAgent().getMask() != null ? strategy.getManagementAgent().getMask() : false;
uri = getDefinition().getExpression().getExpression();
if (sanitize) {
uri = URISupport.sanitizeUri(uri);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:9，代码来源:ManagedEnricher.java
示例8: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
@Override
public void init(ManagementStrategy strategy) {
super.init(strategy);
boolean enabled = context.getManagementStrategy().getManagementAgent().getStatisticsLevel() != ManagementStatisticsLevel.Off;
setStatisticsEnabled(enabled);
exchangesInFlightKeys.clear();
exchangesInFlightStartTimestamps.clear();
}
开发者ID:HydAu，项目名称:Camel，代码行数:10，代码来源:ManagedRoute.java
示例9: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
super.init(strategy);
sanitize = strategy.getManagementAgent().getMask() != null ? strategy.getManagementAgent().getMask() : false;
if (sanitize) {
uri = URISupport.sanitizeUri(processor.getUri());
} else {
uri = processor.getUri();
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:10，代码来源:ManagedWireTapProcessor.java
示例10: init
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public void init(ManagementStrategy strategy) {
super.init(strategy);
this.sanitize = strategy.getManagementAgent().getMask() != null ? strategy.getManagementAgent().getMask() : false;
if (sanitize) {
uri = URISupport.sanitizeUri(processor.getUri());
} else {
uri = processor.getUri();
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:10，代码来源:ManagedSendDynamicProcessor.java
示例11: notifyCamelContextStarting
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStarting(CamelContext context) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStartingEvent(context);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例12: notifyCamelContextStarted
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStarted(CamelContext context) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStartedEvent(context);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例13: notifyCamelContextStartupFailed
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStartupFailed(CamelContext context, Throwable cause) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStartupFailureEvent(context, cause);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例14: notifyCamelContextStopping
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStopping(CamelContext context) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStoppingEvent(context);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例15: notifyCamelContextStopped
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStopped(CamelContext context) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStoppedEvent(context);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例16: notifyCamelContextStopFailed
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyCamelContextStopFailed(CamelContext context, Throwable cause) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreCamelContextEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createCamelContextStopFailureEvent(context, cause);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例17: notifyServiceStopFailure
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyServiceStopFailure(CamelContext context, Object service, Throwable cause) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreServiceEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createServiceStopFailureEvent(context, service, cause);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例18: notifyServiceStartupFailure
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyServiceStartupFailure(CamelContext context, Object service, Throwable cause) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreServiceEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createServiceStartupFailureEvent(context, service, cause);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例19: notifyRouteStarted
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyRouteStarted(CamelContext context, Route route) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreRouteEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createRouteStartedEvent(route);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
示例20: notifyRouteStopped
import org.apache.camel.spi.ManagementStrategy; //导入依赖的package包/类
public static void notifyRouteStopped(CamelContext context, Route route) {
ManagementStrategy management = context.getManagementStrategy();
if (management == null) {
return;
}
List<EventNotifier> notifiers = management.getEventNotifiers();
if (notifiers == null || notifiers.isEmpty()) {
return;
}
for (EventNotifier notifier : notifiers) {
if (notifier.isIgnoreRouteEvents()) {
continue;
}
EventFactory factory = management.getEventFactory();
if (factory == null) {
return;
}
EventObject event = factory.createRouteStoppedEvent(route);
if (event == null) {
return;
}
doNotifyEvent(notifier, event);
}
}
开发者ID:HydAu，项目名称:Camel，代码行数:28，代码来源:EventHelper.java
注：本文中的org.apache.camel.spi.ManagementStrategy类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论