4.17. Spring Boot, Apache Camel 및 외부 메시징 브로커 사용

Fuse는 외부 메시징 브로커를 사용합니다. 지원되는 브로커, 클라이언트 및 Camel 구성 요소 조합에 대한 자세한 내용은 지원되는 구성을 참조하십시오.

Camel 구성 요소는 JMS connection-factory에 연결되어 있어야 합니다. 아래 예제에서는 camel-amqp 구성 요소를 JMS 연결 요소에 연결하는 방법을 보여줍니다.

import org.apache.activemq.jms.pool.PooledConnectionFactory;
import org.apache.camel.component.amqp.AMQPComponent;
import org.apache.qpid.jms.JmsConnectionFactory;
...

AMQPComponent amqpComponent(AMQPConfiguration config) {
       JmsConnectionFactory qpid = new JmsConnectionFactory(config.getUsername(), config.getPassword(), "amqp://"+ config.getHost() + ":" + config.getPort());
       qpid.setTopicPrefix("topic://");

       PooledConnectionFactory factory = new PooledConnectionFactory();
       factory.setConnectionFactory(qpid);

AMQPComponent amqpcomp = new AMQPComponent(factory);