2014-03-05 86 views
0

嗨,我與Apache駱駝掙扎,如何實現在Apache的駱駝事件驅動的消費,讓JMS消息

我想要的「真實」 javax.jms.TextMessage在我的自定義消費者豆。但我得到的只是消息文本字符串。

配置:

 <camelContext xmlns="http://camel.apache.org/schema/spring"> 
    <route id="route_dispatching"> 
     <from uri="activemq:queue:queue.dispatcher.replyqueue"/> 
     <to uri="bean:dispatcherbean"/> 
     </route> 
    </camelContext> 
    <bean id="dispatcherbean" class="com.company.Dispatcher"/> 

調度豆的代碼:

 public class Dispatcher{ 
      private static final Log LOG = LogFactory.getLog(Dispatcher.class); 
      public void handleEvent(Object eventPayload) throws Exception 
      { 
       LOG.info("got an event"); 
      } 
    } 

的eventPayload對象是String類型的,而不是javax.jms.TextMessage。 我試圖改變URI =「的ActiveMQ:隊列URI =」 JMS:隊列,但後來我得到有關失蹤連接工廠:-(一些錯誤

希望有人可以幫助

問候,託比

回答

0

您是否嘗試過將類型從Object更改爲POJO類中的javax.jms.TextMessage?