6.17. Spring Boot、Apache Camel、および外部メッセージングブローカーの使用
Fuse は外部メッセージングブローカーを使用します。サポートされるブローカー、クライアント、および Camel コンポーネントの組み合わせに関する詳細は Red Hat Fuse でサポートされる構成 を参照してください。
Camel コンポーネントは JMS 接続ファクトリーに接続されている必要があります。以下の例は、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);