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);
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);
Copy to Clipboard
Copied!
Toggle word wrap
Toggle overflow