Spring integration JMS在service activator中获取ClassCast异常

Question

我正在使用Spring集成连接到JMS消息队列。我使用的JMS提供程序是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;
}
}

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

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

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

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

谢谢

Answer 1

看起来你的

在这种情况下，整个JmsMessage将显示为Spring集成消息的有效负载。但是正如您所看到的，您的ServiceActivator正好期望JmsMessage的主体。

Answer 2

查看stacktrace、ClassCastException、，

>

先看看你的Entity，实现了什么接口？

第二个in边界Message.getPayload（）. getClass（），实现相同的接口ActiveMQ所需的？

• 解决方案是两个类实现相同的接口