• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号
登陆 注册
描述文字

Java ManagementStrategy类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java RuntimeUtil类代码示例发布时间：2022-05-23
下一篇：
Java AdEvent类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap