JMS - 发送对象消息

3
我想发送JMS中的对象消息,但出现了运行时异常。 请为我提供可能的解决方案。
JMS 代码:
ObjectMessage objMessage = session.createObjectMessage();
        MessageData data = new MessageData();
        objMessage.setObject(data);
        sender.send(objMessage);

在控制台上发现异常:

    log4j:WARN No appenders could be found for logger         org.jboss.remoting.transport.socket.MicroSocketClientInvoker).
    log4j:WARN Please initialize the log4j system properly.
    java.lang.RuntimeException: com.test.SendJMSMessage
at java.io.ObjectOutputStream.writeObject0(Unknown Source)
at java.io.ObjectOutputStream.defaultWriteFields(Unknown Source)
at java.io.ObjectOutputStream.writeSerialData(Unknown Source)
at java.io.ObjectOutputStream.writeOrdinaryObject(Unknown Source)
at java.io.ObjectOutputStream.writeObject0(Unknown Source)
at java.io.ObjectOutputStream.writeObject(Unknown Source)
at org.jboss.messaging.util.StreamUtils.writeObject(StreamUtils.java:249)
at org.jboss.jms.message.JBossObjectMessage.doWriteObject(JBossObjectMessage.java:141)
at org.jboss.messaging.core.impl.message.MessageSupport.getPayloadAsByteArray(MessageSupport.java:216)
at org.jboss.jms.message.JBossObjectMessage.setObject(JBossObjectMessage.java:118)
at org.jboss.jms.message.ObjectMessageProxy.setObject(ObjectMessageProxy.java:59)
at com.test.SendJMSMessage.example(SendJMSMessage.java:36)
at com.test.SendJMSMessage.main(SendJMSMessage.java:130)

创建了新的MessageData类以代替创建子类MessageData之后,当我运行代码时,出现以下异常:
18:26:08,297 ERROR [JmsGatewayListener] Problems invoking method <process>
java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.jboss.soa.esb.listeners.gateway.JmsGatewayListener.doRun(JmsGatewayListener.java:161)
at org.jboss.soa.esb.listeners.lifecycle.AbstractThreadedManagedLifecycle.run(AbstractThreadedManagedLifecycle.java:115)
at java.lang.Thread.run(Unknown Source)

Caused by: java.lang.RuntimeException: No ClassLoaders found for: com.test.MessageData
at org.jboss.mx.loading.LoadMgr3.beginLoadTask(LoadMgr3.java:306)
at org.jboss.mx.loading.RepositoryClassLoader.loadClassImpl(RepositoryClassLoader.java:521)
at org.jboss.mx.loading.RepositoryClassLoader.loadClass(RepositoryClassLoader.java:415)
at java.lang.ClassLoader.loadClass(Unknown Source)
at java.lang.ClassLoader.loadClassInternal(Unknown Source)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Unknown Source)
at java.io.ObjectInputStream.resolveClass(Unknown Source)
at org.jboss.messaging.util.ObjectInputStreamWithClassLoader.resolveClass(ObjectInputStreamWithClassLoader.java:78)
at java.io.ObjectInputStream.readNonProxyDesc(Unknown Source)
at java.io.ObjectInputStream.readClassDesc(Unknown Source)
at java.io.ObjectInputStream.readOrdinaryObject(Unknown Source)
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at org.jboss.messaging.util.StreamUtils.readObject(StreamUtils.java:154)
at org.jboss.messaging.core.impl.message.MessageSupport.readPayload(MessageSupport.java:405)
at org.jboss.jms.message.JBossObjectMessage.getObject(JBossObjectMessage.java:126)
at org.jboss.jms.message.ObjectMessageProxy.getObject(ObjectMessageProxy.java:68)
at org.jboss.soa.esb.listeners.gateway.PackageJmsMessageContents.setESBMessageBody(PackageJmsMessageContents.java:165)
at org.jboss.soa.esb.listeners.gateway.PackageJmsMessageContents.process(PackageJmsMessageContents.java:89)
... 7 more

我正在尝试向ESB服务器代码发送一个对象消息。 针对上述情况,您有什么控制台窗口建议吗?

2个回答

6
异常出现在“另一边”:
at java.io.ObjectInputStream.resolveClass(Unknown Source)
at org.jboss.messaging.util.ObjectInputStreamWithClassLoader.resolveClass(ObjectInputStreamWithClassLoader.java:78)

所以,您发出了消息,但在另一端无法进行反序列化。为什么?因为“另一侧”没有MessageData类定义的类路径。如果是不同的应用程序,则需要将MessageData提取到公共jar中,并在两个应用程序中包含它。
序列化并非魔术;序列化和反序列化方必须都能够访问相同的类定义(.class文件),并且它们的版本必须相同或至少兼容。

如何确保同一个对象不会被创建为两个不同的对象消息... - Krithika Vittal
这与问题有何关联?你有什么具体案例吗? - MaDa
我正在查询数据库并通过队列将数据作为对象发送给客户端。我需要确保在任何时候都不会向用户返回相同的行/对象。 - Krithika Vittal

4

你的 MessageData 类需要实现 java.io.Serializable 接口,这可能是问题所在。还应该有一个额外的“cause”异常堆栈跟踪。


MessageData类实现了java.io.Serializable接口,但仍然存在相同的问题。 - S Singh

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接