Блог

В настоящее время создается соединение amqp путем переопределения setRemoteURI(«») JmsConnectionFactory(qpid apache) application-context.xml

 <bean id="amqpConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory">
        <bean class="com.abc.AMQPSConnectionFactory">
        </bean>
    </property>
</bean>
    
    
<bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
    <property name="testConnectionOnStartup" value="true" />
    <property name="configuration" ref="amqpConfig" />
</bean>
  

Мой AMQPSConnectionFactory — в настоящее время создает соединение amqp с заданным KEYSTORELOCATION, KEYSTOREPASSWORD, KEYSTORETYPE путем переопределения setRemoteURI(«») JmsConnectionFactory, как показано

 public class AMQPSConnectionFactory extends JmsConnectionFactory {
       public AMQPSConnectionFactory() {
        setRemoteURI("URL?jms.prefetchPolicy.queuePrefetch=trueamp;transport.keyStoreLocation=KEYSTORELOCamp;transport.keyStorePassword=KEYSTOREPASSWORDamp;transport.keyStoreType=KEYSTORETYPEamp;transport.trustAll=trueamp;transport.enabledProtocols=TLSv1.2");
    }
}
  

Как я могу создать соединение amqp, передав строку СЕРТИФИКАТА в кодировке base 64 (вместо KEYSTORELOCATION), ПАРОЛЬ этого сертификата в кодировке base 64 (вместо KEYSTOREPASSWORD) и KEYSTORETYPE во время выполнения?

Проблема: я не могу сохранить сертификат по пути (чтобы указать МЕСТОПОЛОЖЕНИЕ ключа в uri), но мне нужно использовать саму строку сертификата

Наиболее близким соответствием тому, что вы просите, является переопределение SSLContext, которое позволяет вам предоставить свой собственный SSLContext, который клиент будет использовать во время SSL-квитирования. Не существует механизма предоставления сертификата непосредственно фабрике соединений, и я сомневаюсь, что какой-либо такой механизм будет добавлен.

  JmsConnectionFactory factory = new JmsConnectionFactory("amqps://localhost:5673");
 factory.setSslContext(<your-own-context>);