Camel Http4 2.12.2: «httpClientConfigurer» не может быть выведен из endpointUri

Question

Я использую scala akka-camel с компонентом http4 (версия 2.12.2). Я создаю производитель Camel с конечной точкой:

def endpointUri = "https4://host-path" + 
    "?bridgeEndpoint=true" + 
    "&httpClientConfigurer=#configurer" + 
    "&clientConnectionManager=#manager" 

где configurerHttpClientConfigurer является зарегистрированным в Camel контексте реестре (тот же принцип применит и к manager).

Когда я посылаю CamelMessage к этой конечной точке я могу увидеть в AKKA бревен этого:

DEBUG o.a.c.component.http4.HttpComponent - Creating endpoint uri https4://host-path?bridgeEndpoint=true&httpClientConfigurer=#configurer&clientConnectionManager=#manager 
DEBUG o.a.camel.util.IntrospectionSupport - Configured property: clientConnectionManager on bean: Endpoint["https4://host-path?bridgeEndpoint=true&httpClientConfigurer=#configurer&clientConnectionManager=#manager"] with value: org.apache.http.impl.conn.PoolingClientConnectionManager@3da3d36f 
DEBUG o.a.camel.util.IntrospectionSupport - Configured property: bridgeEndpoint on bean: Endpoint["https4://host-path?bridgeEndpoint=true&httpClientConfigurer=#configurer&clientConnectionManager=#manager"] with value: true 
INFO o.a.c.component.http4.HttpComponent - Registering SSL scheme https on port 443 
INFO o.a.c.component.http4.HttpComponent - Registering SSL scheme https4 on port 443 

Так httpClientConfigurer не настроен, и я не знаю, почему он игнорирует этот параметр. Я искал любую связанную с ней проблему в Apache Camel, но я ничего не нашел.

Любая идея? Спасибо заранее.

Answer 1

И наконец, это разрешено. Я не использовал ни одного из clientConnectionManager или httpClientConfigurer. Я использовал SSLContextParams и признак TlsConfigurer, который должен быть смешанным с Продюсером.

Я хочу использовать различные сертификаты X509, так как верблюд говорит:

Важно: только один экземпляр org.apache.camel.util.jsse.SSLContextParameters поддерживается за HttpComponent. Если вам нужно использовать 2 или более разных экземпляра, вам нужно определить новый HttpComponent для каждого экземпляра, который вам нужен.

Поэтому TlsConfigurer configure метод должен иметь возможность получить экземпляр в http4 компонента из контекста верблюд, а затем применить SSLContextParams и добавить измененный экземпляр в качестве нового компонента в контексте верблюд.

Вот как это выглядит:

import org.apache.camel.component.http4.HttpComponent 
import org.apache.camel.util.jsse._ 

trait TlsConfigurer { 
    self: {val camel: akka.camel.Camel} => 

    def configure(
     componentName: String, 
     keyStorePath:String, 
     trustStorePath:String, 
     password: String) { 

     val ksp = new KeyStoreParameters 
     ksp.setResource(keystorePath) 
     ksp.setPassword(password) 

     val kmp = new KeyManagersParameters 
     kmp.setKeyStore(ksp) 
     kmp.setKeyPassword(password) 

     val scp = new SSLContextParameters 
     scp.setKeyManagers(kmp) 

     val httpComponent = 
      camel.context.getComponent("http4",classOf[HttpComponent]) 
     httpComponent.setSslContextParameters(scp) 

     camel.context.addComponent(componentName, httpComponent) 

    } 

} 

Таким образом, можно создать два различных конечных точек: http-client1://... и http-client2://... и управлять сертификатами в отдельном пути.

Answer 2

httpClientConfigurer не установлен в HttpEndpoint с помощью IntrospectionSupport, поэтому вы не видите журнал отладки. Я думаю, что мы собираемся узнать, как настраивается сценарий, когда вы добавляете некоторый журнал в конфигуратор клиента.