Spring integration + JMS + getting ClassCast exception in service activator

Question

I am using Spring integration to connect to JMS Messaging queues. JMS Provider I am using is Apache ActiveMQ.

I have following class which reads JMS messages (having ServiceActivator method):

@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;
}
}

Over here, Entity is a POJO in my application.

While reading message from JMS-queue, I get following exception:

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

How should I solve this?

Thanks

It looks like you are trying to use the framework(s) incorrectly; you need to show the full stack trace and exactly how you are configuring the app. — Gary Russell

Marcelo Ferreira Marcelo Ferreira · Accepted Answer · 2016-08-26T11:28:50

See your stacktrace, ClassCastException,

First see your Entity, what interface has implement?
Second inboundMessage.getPayload().getClass(), implement same interface ActiveMQ required?
- Solution for this the both class implement same interface.
- Other reader one class make a converter other class.
- Other problema, spring configuration correct for use integration ActiveMQ

Spring integration + JMS + getting ClassCast exception in service activator

2 Answers