1

有没有办法在骆驼路线过程中将对象放入消息中。

假设我有一条路线

from("direct:send")
.process(queueProcessor)
.to(activemqEndPoint)

在 queueProcessor 中,我将一个对象放入交换中,

现在,我有一个监听器来监听 activemqE​​ndPoint(queue)

public void onMessage(Message message) {
    try {
        //here i want to get the message i set it in the exchange
     }

有什么帮助吗??提前致谢

4

2 回答 2

1

尝试这对我有用

from("direct:send")
.process(queueProcessor)
.to(parallelQueue + "?jmsMessageType=Object")
于 2013-08-11T20:37:55.647 回答
0

当然,Camel 会将ActiveMQObjectMessage放入队列中,您只需将消息转换回您的对象类型...

ActiveMQObjectMessage 消息 = (ActiveMQObjectMessage) 消息;

MyObject myObj = (MyObject) message.getObject();

于 2013-08-09T03:25:19.853 回答