java - 如何通过 Java 代码(而不是通过 JMS API - 生存时间)在 WebSphere MQ(队列)中设置消息过期时间

Question

有人可以分享用于设置队列中消息过期的 WebSphere 代码吗？

我知道有一个 JMSAPI 可以设置消息的过期时间。\

但是此 JMS-API 不适用于 Java 代码的 WebSphere MQ API。

我正在使用以下代码来生成消息。

MQMessage.write 和 MQMessage.writeUTF

问候卡西克

Answer 1

使用链接获取更多信息。以下是 MQ/Java 应用程序的基础知识:

MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.options = CMQC.MQPMO_FAIL_IF_QUIESCING;

MQMessage sendmsg = new MQMessage();
sendmsg.messageId    = CMQC.MQMI_NONE;
sendmsg.correlationId= CMQC.MQCI_NONE;
sendmsg.format       = CMQC.MQFMT_STRING;
sendmsg.messageType  = CMQC.MQMT_DATAGRAM;
sendmsg.expiry       = timeToLive; // expiry is in tenths of a second
sendmsg.write(msg.getBytes());

outQ(sendmsg, pmo);