使用jms队列中的消息
使用jms队列中的消息
提问于 2013-09-18 19:51:33
如何在下面的代码中消费放在"jmsQueueConsumer:queue:consumer.queue“上的消息：
CamelContext context1 = new DefaultCamelContext();
ConnectionFactory connectionFactory1 = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
ConnectionFactory connectionFactory2 = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
context1.addComponent("jmsQueueProducer", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory1));
context1.addComponent("jmsQueueConsumer", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory2));
context1.addRoutes(new RouteBuilder() {
public void configure() {
from("jmsQueueProducer:queue:producer.queue").to("jmsQueueConsumer:queue:consumer.queue");
}
});
ProducerTemplate template = context1.createProducerTemplate();
context1.start();
for (int i = 0; i < 10; i++) {
template.sendBody("jmsQueueProducer:queue:producer.queue", "Test Message: " + i);
}Stack Overflow用户
发布于 2013-09-18 20:02:00
您可以配置另一个路由来处理它。例如：
from("jmsQueueConsumer:queue:consumer.queue")
.process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
// your processing code here
}
})
.to(any other endpoint)此外，您还可以将您的处理器提取为单独的类。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/18871498
复制相关文章
相似问题
腾讯云开发者
