【问题标题】:How to implement an event-driven consumer in Apache Camel and get JMS Message如何在 Apache Camel 中实现事件驱动的消费者并获取 JMS 消息
【发布时间】:2014-04-08 01:23:20
【问题描述】:

您好,我正在努力使用 Apache Camel,

我想要自定义 Consumer-Bean 中的“真实”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"/>

Dispatcher Bean 代码:

     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:queue 更改为 uri="jms:queue,但随后出现一些关于缺少连接工厂的错误:-(

希望有人可以提供帮助?

问候,托比

【问题讨论】:

    标签: java spring jms apache-camel activemq


    【解决方案1】:

    您是否尝试过在 POJO 类中将类型从 Object 更改为 javax.jms.TextMessage?

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2019-06-03
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2011-08-05
      • 1970-01-01
      相关资源
      最近更新 更多