0

我有一个奇怪的问题

ActiveMQ 是消息服务器，使用 AMQP 发送消息

当我在同一个 Eclipse 项目中同时拥有发布者和订阅者时。我可以发送发送 ObjectMessage 并接收没有任何问题

但是，当我将订阅者和发布者拆分为两个不同的 Eclipse 项目时，我得到了

javax.jms.MessageNotReadableException: Message body is write-only

这是我发送的对象的类

public class Test1 implements Serializable{

    private String x;

    public Test1( String x){
        this.x = x;
    }
}

这是个例外

javax.jms.MessageNotReadableException: Message body is write-only
        at org.apache.activemq.command.ActiveMQBytesMessage.checkWriteOnlyBody(ActiveMQBytesMessage.java:863)
        at org.apache.activemq.command.ActiveMQBytesMessage.initializeReading(ActiveMQBytesMessage.java:868)
        at org.apache.activemq.command.ActiveMQBytesMessage.getBodyLength(ActiveMQBytesMessage.java:190)
        at org.apache.qpid.proton.jms.AMQPNativeOutboundTransformer.transform(AMQPNativeOutboundTransformer.java:63)
        at org.apache.qpid.proton.jms.AutoOutboundTransformer.transform(AutoOutboundTransformer.java:37)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter$ConsumerContext.pumpOutbound(AmqpProtocolConverter.java:751)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter$ConsumerContext.onMessageDispatch(AmqpProtocolConverter.java:710)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onActiveMQCommand(AmqpProtocolConverter.java:300)
        at org.apache.activemq.transport.amqp.AmqpTransportFilter.oneway(AmqpTransportFilter.java:64)
        at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1378)
        at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:897)
        at org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:943)
        at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
        at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:679)

这是我遵循的代码

https://fisheye6.atlassian.com/browse/activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java?r=1406466&r=1414990

4

2 回答 2

2

这应该是带有 AMQ 的 ActiveMQ 中的一个错误

此错误发生在两个可重现的条件下

  1. 将对象作为消息发送（当前无法发送对象）
  2. 当消费者遇到一些异常时

这里值得注意的是

这绝不会影响正在传输的消息。您只会看到异常，但数据传输会正常工作！！！

于 2013-05-14T10:59:37.473 回答
0

这听起来像一个错误，在 ActiveMQ 站点上打开一个 Jira 问题并发布一个测试用例，我认为这里没有任何神奇的开关来修复异常。无需发布您的代码，这就是我们所能说的。

于 2013-04-09T13:55:08.323 回答