使用JMS ObjectMessage时发生ClassNotFound异常

Question

我通过Spring Boot中编写的侦听器使用JMS对象消息。我正在通过我的Camel应用程序将ObjectMessage发送到ActiveMQ队列，我正在Spring Boot应用程序中的侦听器类中侦听队列。

代码：

final BindyCsvDataFormat bindy = new BindyCsvDataFormat(EquityFeeds.class);
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
CamelContext _ctx = new DefaultCamelContext(); 
_ctx.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
_ctx.addRoutes(new RouteBuilder() {

    public void configure() throws Exception {
        from("file:src/main/resources?fileName=data.csv")               
            .unmarshal(bindy)
            .split(body())
            .streaming().to("jms:queue:javaobjects.upstream.queue");
    }
});

这是我的POJO类EquityFeeds：

@CsvRecord(separator = ",",skipFirstLine = true)
public class EquityFeeds implements Serializable {

    private static final long serialVersionUID = 1L;

    @DataField(pos = 1) 
    private String externalTransactionId;

    @DataField(pos = 2)
    private String clientId;

    // other fields and getters setters
    ...

在ActiveMQ队列中，我收到的消息为：

camelproject.EquityFeeds@1665425

我在Spring Boot中的JMS侦听器：

@JmsListener(destination = "javaobjects.upstream.queue")
public void capitalIQProcessor(final Message objectMessage) throws JMSException {
    Object messageData = null;

    if(objectMessage instanceof ObjectMessage) {
        ObjectMessage objMessage = (ObjectMessage) objectMessage;
        System.out.println("Starting Object Message.");

        Object object = objMessage.getObject();

        EquityFeeds equityFeeds = (EquityFeeds) object;

        System.out.println("Object: "+equityFeeds.toString());
    }    
}

我得到一个Exception@line对象对象=Object Message.getObject（）；：

capitalIQProcessor(javax.jms.Message) throws javax.jms.JMSException' threw exception; nested exception is javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: camelproject.EquityFeeds. Caused by: javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFoundException: camelproject.EquityFeeds. Caused by: java.lang.ClassNotFoundException: camelproject.EquityFeeds

通过堆栈溢出和网络上的其他帖子，我做了以下更改：

>

1. 然后添加条目：wrapper.java.classpath.3=C:\Users\sidbharg\eclipse workspace\Sid\target\camelproject-0.0.1-SNAPSHOT。jar这是.jar文件的位置，我的POJO（EquityFeeds）在这里

在我的消费者代码中，我还添加了activeMQConnectionFactory.setTrustAllPackages（true） ：

public ActiveMQConnectionFactory activeMQConnectionFactory() {
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
        activeMQConnectionFactory.setBrokerURL(brokerURL);
        activeMQConnectionFactory.setTrustAllPackages(true);
        return activeMQConnectionFactory;
}

现在问题是什么？为什么给我例外。我哪里出错了？有什么我忘记了需要补充的吗？

Answer 1

你需要一个项目。EquityFeeds在使用JMS的应用程序的类路径上。显然JVM找不到它，因此抛出了一个java.lang.ClassNotFoundException。

此外，您不需要对代理的wrapper.conf进行这些更改。侦听器正在尝试反序列化消息，而不是代理。