Qpid JMS：接收文本消息导致转换异常

Question

我正在尝试使用 Qpid JMS 和 ProtonJ (AMQP 1.0) 发送和接收消息，但无法接收 TextMessage。异常表示它不能将 JmsBytesMessage 转换为 TextMessage:

org.apache.qpid.jms.message.JmsBytesMessage cannot be cast to javax.jms.TextMessage

即使尝试以 JmsTextMessage 形式接收消息也会导致：

org.apache.qpid.jms.message.JmsBytesMessage cannot be cast to org.apache.qpid.jms.message.JmsTextMessage

我正在发送消息如下：

  TextMessage textMessage = session.createTextMessage(message)
  Queue queue = session.createQueue(queueName); 
  MessageProducer producer = session.createProducer(queue);
  producer.send(textMessage);

我尝试通过以下方式接收消息：

    Queue queue = session.createQueue(queueName); 
    MessageConsumer consumer = session.createConsumer(queue);
    connection.start();
    TextMessage message = (TextMessage) consumer.receive();

由于这不起作用，我尝试获取字节并使用 toString 方法：

 JmsBytesMessage message = (JmsBytesMessage) consumer.receive();  
 String stringMessage = message.toString();

结果如下：

JmsBytesMessage { org.apache.qpid.jms.provider.amqp.message.AmqpJmsBytesMessageFacade@10664b39 }

在接下来的测试中，我只使用字节并将它们转换为字符串：

 JmsBytesMessage message = (JmsBytesMessage) consumer.receive();
 message.readUTF();
 byte[] byteData = null;
 byteData = new byte[(int) message.getBodyLength()];
 message.readBytes(byteData);
 message.reset();
 String messageString = new String(byteData);

结果是Sw�testmessage。我想知道那个前缀是什么，因为我还没有发送它。我想这一定是一些编码的东西。

如何接收字符串形式的消息？

Answer 1

QPid JMS 将 return 基于用于描述入站消息的编码和注释方式的传入消息的基于 TextMessage 的变体。如果您收到一个 BytesMessage 那么它意味着正在传递的消息没有被注释为 TextMessage 或者它没有携带一个内容类型表明一个字符串被编码在正文字节中或者它不是一个 AmqpValue 类型的正文部分它带有一个编码的字符串。

您的中间人可能没有正确地重新编码邮件，或者您有其他未正确编码的排队邮件。

Qpid JMS：接收文本消息导致转换异常

Qpid JMS: Receiving Text Message leads to casting exception

java

jms

qpid