scala - 如何为 akka-camel 端点启用 JMX 监控

Question

我有一个 Akka 应用程序(akka 2.2.0、akka-camel、camel 2.10.5)。 该应用程序包括生产者组件，即:

class MyProducer extends Actor with Producer with akka.actor.ActorLogging {
...

我想让 Camel 通过 JMX 自动公开这些生产者的监控属性，以查看已交换了多少消息、平均时间、吞吐量等。

理论上Apache Camel has extensive support for JMX to allow you to monitor and control the Camel managed objects with a JMX client .实际上，我启用了 JMX 代理

    <jmxAgent
            id="agent"
            disabled="false"
            createConnector="true"
            usePlatformMBeanServer="true"
            mbeanServerDefaultDomain="localhost"
            registryPort="1346"
            registerAlways="true"
            registerNewRoutes="true"
            />

这导致一系列 Camel 信息显示为 mbean(例如，从 VisualVM 中可以看到)但是“端点”下没有关于我的 Producer 参与者的信息。

我试过用 actor 装饰

@ManagedResource

这似乎没有任何效果。 文档说

"In Camel 2.1 onwards only singleton endpoints are registered as the overhead for non singleton will be substantial in cases where thousands or millions of endpoints are used. This can happens when using a Recipient List EIP or from a ProducerTemplate that sends a lot of messages. "

我想知道我的 Producer actor 是否因此不公开信息(我不清楚 Producer 特征产生的端点类型到底是什么)。

我到底需要做什么才能为我的 akka-camel 端点启用 JMX 监控(因为使用生产者特征)？

编辑: Viktor 指出我需要重新定义一个配置属性。 这是必要的，但还不够。还需要强制 Camel 管理您的端点。我必须添加这个:

camelContext.addRegisterEndpointCallback(new EndpointStrategy {
  def registerEndpoint(name: String, ep: Endpoint) = {
    camelContext.getManagementStrategy.manageObject(ep)
    ep
  }
})

Answer 1

Akka 文档非常广泛。

akka {
  camel {
  # Whether JMX should be enabled or disabled for the Camel Context
  jmx = off
  …
  }
}

• http://doc.akka.io/docs/akka/2.2.0/general/configuration.html#akka-camel