0
我有很简单的POJO类:Apache的骆驼:为什么我不能发送豆文字JMS
public class MessageBean {
String text;
public String getMessage()
{
return text;
}
}
和骆驼航线:
public static void main(String[] args) {
final MessageBean bean = new MessageBean();
bean.text = "This is the text";
CamelContext context = new DefaultCamelContext();
ConnectionFactory conFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
context.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(conFactory));
try {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct:hello").process(new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.getIn().setBody(bean);
}
}).setBody(simple("${body.message}")).to("jms:queue:Test.Queue");
}
});
} catch (Exception e) {
e.printStackTrace();
}
try {
context.start();
Thread.sleep(5000);
context.stop();
} catch (Exception e) {
e.printStackTrace();
}
}
我不明白为什么我不能从bean变量text
发送文本到activemq队列?
当我尝试从文件夹发送txt文件时,它正确发送到队列中的jms。
你只需要使用ProducerTemplate发送消息踢的路线(它甚至可能是一个空的消息)。 – 2014-11-23 02:04:34