java - ObjectMessage.setObject() 抛出 javax.jms.JMSException 没有明显的原因

标签 java glassfish jms

有一个像这样的自定义对象:

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 *

}

然后我尝试将包含自定义消息对象的 ObjectMessage 发送到我的 jms 队列:

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)

那么问题出在哪里呢?我在代码中没有发现任何错误,并且我的对象是可序列化的。

最佳答案

我用谷歌来分析你的错误消息:

[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 也不可序列化。

<小时/>

回答“为什么会出现此异常而不是 NotSerializedException”的问题?

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

<小时/>

我不明白的是:为什么您希望您的 MessageObject 包含包装的 TextMessage?为什么不将文本本身添加到您的 MessageObject 中?

关于java - ObjectMessage.setObject() 抛出 javax.jms.JMSException 没有明显的原因,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53252277/

相关文章:

java - JPA DBUnit HsqlDb : Disable constraint checks?

java - 如果从InputStream保存文件期间发生错误,删除文件是否安全?

web-services - Glassfish 4.0 加载应用程序时出现异常,java.lang.IllegalStateException

jakarta-ee - 如果使用 Maven 更改包名称,则无法使用 Netbeans 部署 Ear

java.lang.UnsatisfiedLinkError 错误

java - 在先前的 JavaScript 错误之后,正文中的脚本标签不会被评估

c# - 为什么预处理器在 C/C++/ObjC 以外的语言中不太常见?

apache - 为什么在 Glassfish 或 Tomcat 之前使用 Apache Web Server?

java - session 关闭时 ActiveMQ 消息消失

java - JMS 订户客户端 ID 可以跨主机迁移吗?