可以使自己共享WebSphere Code来设置Queue中消息的过期时间。

我知道这是一个JMSAPI来设置消息的过期时间。

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

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

MQMessage.write和MQMessage.writeUTF

问候
卡尔提克

最佳答案

使用链接获取更多信息。这是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);

关于java - 如何通过Java代码(而不是JMS API-生存时间)在WebSphere MQ(队列)中设置消息到期时间,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/36307705/

10-14 12:40