-1
activemq의 소비자 측에 낙타를 통합해야합니다. 나는 activemq를 설정하고 소비자 언어로 낙타 (java DSL을 사용)를 구성하려고하지만 저에게는 효과가 없습니다. 여기에 코드가 있습니다 :Apache Camel을 통해 메시지 받기?
public class TestConsumer {
static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
static String subject = "Test-AMQ";
public static void main(String[] args) throws Exception {
CamelContext context = new DefaultCamelContext();
BrokerService broker = new BrokerService();
//broker.addConnector(url);
//broker.setBrokerName("localhost");
broker.start();
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost?create=false&waitForStart=10000");
context.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
context.addRoutes(new Routes());
context.start();
}
}
class Routes extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:"+new TestConsumer().subject).process(new Processor() {
@Override
public void process(Exchange arg0) throws Exception {
System.out.println("Camel Test Message: " + arg0.toString());
}
});
}
}
"Test-AMQ"는 AMQ 대기열 이름입니다. –
"작동하지 않음"은 무엇을 의미합니까? 예외가 있습니까? –
또한'vm : // localhost'는 내장 브로커를 사용합니다. –