我的代码正在侦听IBM MQ。接收JMS BytesMessage,将其转换为接收器类中的字符串,并将相同的JMS BytesMessage传递给另一个处理器类。处理器类再次将其转换为String。接收器类和处理器类都使用如下相同的代码从BytesMessage获取字符串。我在Receiver类中获取正确的字符串,但是当尝试从Processor类中的BytesMessage获取字符串时,它返回的空字符串。请告知除了保留JMS BytesMessage之外还必须执行的操作,以便它也可以在Processor类中转换为String。
将消息发送到处理器的代码:
String strMessage = null;
strMessage = getStringFromMessage(Message message)
process(message)
用于字符串转换的代码:
if (message instanceof BytesMessage){
BytesMessage byteMessage = (BytesMessage) message;
byte[] byteData = null;
byteData = new byte[(int) byteMessage.getBodyLength()];
byteMessage.readBytes(byteData);
stringMessage = new String(byteData);
}
最佳答案
我找到了解决方案。我是第一次阅读邮件后添加了以下代码
byteMessage.reset()
这已将光标位置重置为开始位置,因此我能够在处理器中读取它。所以我在接收器中的最终代码将如下所示
if (message instanceof BytesMessage){
BytesMessage byteMessage = (BytesMessage) message;
byte[] byteData = null;
byteData = new byte[(int) byteMessage.getBodyLength()];
byteMessage.readBytes(byteData);
byteMessage.reset();
stringMessage = new String(byteData);
}
再次读取它的原因是我开始在接收器中读取它以执行一些恢复功能。我想在不涉及框架的情况下实现这一目标。最初的框架是仅在处理器中读取消息。