在akka-骆驼演员下访问Camel/Jetty实例

Question

我有一个基本的Jetty实例，它使用akka和scala的akka-camel库。例：

class RestActor extends Actor with Consumer {
    def endpointUri = "jetty:https://0.0.0.0:443/"
    def receive = {
        case msg: CamelMessage => {
            ...
        }
        ...
    }
    ...
}

我想将一个SslSocketConnector绑定到底层的jetty实例，以便加载我的SSL，但是我的问题是，我无法弄清楚如何获得一个处理底层jetty实例的方法来调用addConnector()函数。我的一个想法是将骆驼特性添加到我的类中(例如: RestActor用Camel扩展Actor with )来访问Camel的"context“变量，但是编译器抱怨这样做会覆盖Akka的演员特性中也存在的"context”变量。

Answer 1

下面的代码似乎提供了对底层Camel对象的访问。

class RestActor extends Actor with Consumer {
    val camel = CamelExtension(context.system).context
    def endpointUri = "jetty:https://0.0.0.0:443/"
    def receive = {
        case msg: CamelMessage => {
            ...
        }
        ...
    }
    ...
}

编辑:我包含的最后代码，成功运行Jetty /SSL使用akka的scala骆驼库，为任何人寻找一个例子，如何在未来实现这一点。

class RestActor extends Actor with Consumer {

    val ksp: KeyStoreParameters = new KeyStoreParameters();
    ksp.setResource("/path/to/keystore");
    ksp.setPassword("...");
    val kmp: KeyManagersParameters = new KeyManagersParameters();
    kmp.setKeyStore(ksp);
    val scp: SSLContextParameters = new SSLContextParameters();
    scp.setKeyManagers(kmp);
    val jettyComponent: JettyHttpComponent = CamelExtension(context.system).context.getComponent("jetty", classOf[JettyHttpComponent])
    jettyComponent.setSslContextParameters(scp);

    def endpointUri = "jetty:https://0.0.0.0:8443/"
    def receive = {
        case msg: CamelMessage => {
            ...
        }
        ...
    }
    ...
}