【发布时间】:2019-04-14 14:10:21
【问题描述】:
有一个像这样的自定义对象:
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)
那么问题是什么?我在我的代码中没有发现任何错误,而且我的对象是可序列化的。
【问题讨论】:
-
TextMessage也可以序列化吗? -
@ThomasKläger 我不确定。你认为那是问题吗?错误应该是“异常不可序列化”而不是我得到的错误吗?