ObjectMessage.setObject() 无缘无故抛出 javax.jms.JMSException

Question

有这样的自定义对象：

package Messages;

import java.io.Serializable;
import javax.jms.TextMessage;

public class MessageObject implements Serializable{

private static final long serialVersionUID = 1L;
private TextMessage message;
private String state; 
private String sender;
private String receiver;

public MessageObject() {

}

public TextMessage getMessage() {
    return message;
}

public void setMessage(TextMessage message) {
    this.message = message;
}
* the rest of the getters and setters *

}

然后我创建并尝试向我的 jms 队列发送一个包含我的自定义消息对象的 ObjectMessage：

try {
        Context context = new InitialContext();

        QueueConnectionFactory factory = 
        (QueueConnectionFactory)context.lookup("tiwconnectionfactory");
        Queue queue = (Queue) context.lookup("tiwqueue");
        Connection connection = factory.createConnection();
        connection.start(); 
        Session session= connection.createSession(false, 
        javax.jms.Session.AUTO_ACKNOWLEDGE);

        MessageProducer producer = session.createProducer(queue);


        MessageObject mymessage = new MessageObject();


         ObjectMessage object = session.createObjectMessage();


        TextMessage message = session.createTextMessage();
        message.setText("Hi");


        mymessage.setState("still not read");
        mymessage.setMessage(message);
        mymessage.setSender("Peter");
        mymessage.setReceiver("John");


        object.setObject(mymessage);


        producer.send(object);

尝试运行代码时，抛出的异常是：

[2018-11-11T19:20:07.270+0100] [glassfish 5.0] [SEVERE] [] [] [tid: _ThreadID=28 _ThreadName=Thread-9] [timeMillis: 1541960407270] [levelValue: 1000] [[ javax.jms.JMSException:MQJMSRA_DM4001::Exception:ObjectMessage.setObject()object=Messages.MessageObject@d8b66e3:message=com.sun.messaging.jms.ra.DirectTextPacktatcom.sun.messaging.jms.ra.DirectObjectPacket.setObject(DirectObjectPacket.java:218)

那么问题是什么？我在我的代码中没有发现任何错误，而且我的对象是可序列化的。

Answer 1

我用google来分析你的错误信息：

[2018-11-11T19:20:07.270+0100] [glassfish 5.0] [SEVERE] [] [] [tid: _ThreadID=28 _ThreadName=Thread-9] [timeMillis: 1541960407270] [levelValue: 1000] 
[[ javax.jms.JMSException:MQJMSRA_DM4001::Exception:ObjectMessage.setObject()
  object=Messages.MessageObject@d8b66e3:
  message=com.sun.messaging.jms.ra.DirectTextPacket
  at com.sun.messaging.jms.ra.DirectObjectPacket.setObject(DirectObjectPacket.java:218)

看来TextMessage对象实际上是com.sun.messaging.jms.ra.DirectTextPacket的一个实例。

但是，要使您的 MessageObject 可序列化，其所有字段也需要可序列化。由于 DirectTextPacket 不可序列化，因此您的 MessageObject 不可序列化。

回答问题"why do you get this exception instead of NotSerializableException"?

这是因为 JMS 将类似 NotSerializableException 的异常包装到它自己的异常中。

我不明白的是：你为什么要 MessageObject 包含一个包装的 TextMessage？为什么不将文本本身添加到您的 MessageObject 中？

ObjectMessage.setObject() 无缘无故抛出 javax.jms.JMSException

ObjectMessage.setObject() throws javax.jms.JMSException for no apparently reason

java

jms

glassfish