Spring Boot和Camel-日志路线持续时间

Question

我正在迁移一个应用程序以使用最新版本的 Spring Boot。目前所有的骆驼路线都是XML格式的，我使用这种方法运行它。

所有路由当前都会在处理结束时记录一条消息。我想知道是否有一种方法可以检测特定路由执行和添加到日志消息所用的时间。有了这些信息，我们就可以创建数据狗仪表盘来显示骆驼路线的统计数据

先谢了Damien

Answer 1

public class MyLoggingSentEventNotifer extends EventNotifierSupport {

  public void notify(EventObject event) throws Exception {

    if (event instanceof ExchangeCompletedEvent) {;
      ExchangeCompletedEvent completedEvent = (ExchangeCompletedEvent) event;
      Exchange exchange = completedEvent.getExchange();
      String routeId = exchange.getFromRouteId();
      Date created = ((ExchangeCompletedEvent) event).getExchange()
                        .getProperty(Exchange.CREATED_TIMESTAMP, Date.class);
      // calculate elapsed time
      Date now = new Date();
      long elapsed = now.getTime() - created.getTime();
      log.info("Took " + elapsed + " millis on the route : " + routeId);
    }

 }

 public boolean isEnabled(EventObject event) {
        // we only want the sent events
        return event instanceof ExchangeSentEvent;
 }

 protected void doStart() throws Exception {
        // noop
 }

 protected void doStop() throws Exception {
        // noop
 }

}

context.getManagementStrategy().addEventNotifier(new MyLoggingSentEventNotifer());

参考

https://people . Apache . org/~ dkulp/camel/event notifier-to-log-details-about-all-sent-exchange . html

更新

Exchange.CREATED_TIMESTAMP不再存储为Exchange属性，但您应该在Exchange上使用getCreted方法。