Spring 集成 + JMS + 在服务激活器中获取 ClassCast 异常答案

【问题标题】：Spring integration + JMS + getting ClassCast exception in service activatorSpring 集成 + JMS + 在服务激活器中获取 ClassCast 异常
【发布时间】：2017-01-03 01:12:39
【问题描述】：

我正在使用 Spring 集成连接到 JMS 消息队列。我使用的 JMS Provider 是 Apache ActiveMQ。

我有以下读取 JMS 消息的类（具有 ServiceActivator 方法）：

@Component
public class MessageReader
{

@ServiceActivator
public Entity onMessage(Message<Entity> inboundMessage) {

    System.out.println(" -------Message Read Start--------");

    System.out.println(inboundMessage.getHeaders());

    System.out.println(" -------Message Headers Reading completed--------");

    Entity payload = null;


    try{

        payload = inboundMessage.getPayload();
        System.out.println(" -------Message Read End--------");
    }catch(Exception e){
        e.printStackTrace();
    }


    return payload;
}
}

在这里，Entity 是我的应用程序中的 POJO。

从 JMS 队列读取消息时，我收到以下异常：

java.lang.ClassCastException: org.apache.activemq.command.ActiveMQObjectMessage cannot be cast to com.poc.pojo.Entity

我应该如何解决这个问题？

谢谢

【问题讨论】：

您似乎在尝试错误地使用框架；您需要显示完整的堆栈跟踪以及您是如何配置应用程序的。

标签： spring spring-integration spring-jms

【解决方案1】：

查看您的堆栈跟踪、ClassCastException，

先看看你的Entity，实现了什么接口？
第二个inboundMessage.getPayload().getClass()，需要实现同样的接口ActiveMQ？
- 解决方案，这两个类都实现了相同的接口。
- 其他阅读器一类制作转换器另一类。
- 其他问题，spring 配置正确使用集成 ActiveMQ

【讨论】：

实体类只实现可序列化接口
如果实体类也扩展了“ActiveMQObjectMessage”，则获得相同的 ClassCast 异常：公共类实体扩展 ActiveMQObjectMessage 实现可序列化

【解决方案2】：

您的 <int-jms:message-driver-channel-adapter> 似乎配置了 `extract-payload="false"。

在这种情况下，整个 JmsMessage 将显示为 Spring Integration Message 的 payload。但是正如您所看到的，您的 ServiceActivator 完全期望 JmsMessage 的正文。

【讨论】：

是的，我设置了`extract-payload="false"。我应该如何解决这个问题？我需要阅读两个标题以及正文。
Spring Integration 将所有 JMS 标头映射到 MessageHeaders。 Plus 将 JmsMessage.body 转换为有效负载。所以，保持服务方法不变，但尝试不使用extract-payload。看起来您对 JMS 消息和 Spring 集成消息感到困惑。请仔细阅读 Spring Integration Reference Manual 中的 JMS 章节。