消息選擇器是否也可以與 receiveNowait() 方法一起用于同步過程。它適用于receive() 方法，但想知道IBM mq 的receiveNoWait。創(chuàng)建消費(fèi)者時(shí)添加消息選擇器。編輯 1：我已經(jīng)使用 receiveNowait() 方法進(jìn)行了測(cè)試，并且選擇器不起作用。我不知道問題出在我的選擇器或 receivenowait 方法上。以下是我使用的選擇器：String messageSelector = "JMSTimestamp <= " + System.currentTimeMillis() - 180000;
receiver = (MessageConsumer) session.createConsumer(replyQueue, messageSelector);這意味著，接收者只能接收比當(dāng)前時(shí)間早 3 分鐘的消息。誰(shuí)能弄清楚是什么問題。編輯2：完成測(cè)試后，我發(fā)現(xiàn)問題出在選擇器上，JMSTimeStamp 在選擇器表達(dá)式中的正確用法是什么？
3 回答
肥皂起泡泡
TA貢獻(xiàn)1829條經(jīng)驗(yàn) 獲得超6個(gè)贊
pepared system.currnetTimeMillis() 值在選擇器運(yùn)行時(shí)不會(huì)更新。
在這里，您將在初始化選擇器時(shí)修復(fù)“當(dāng)前”時(shí)間戳。您應(yīng)該為您的查詢執(zhí)行類似“endValidityDate <= (JMSTimestamp-24 60 1000)”的查詢（與任何使用固定值而不是動(dòng)態(tài)值的 SQL 查詢相同的問題）。
森欄
TA貢獻(xiàn)1810條經(jīng)驗(yàn) 獲得超5個(gè)贊
我不能專門談?wù)?IBM MQ 實(shí)現(xiàn)，但從 JMS 的角度來看，JMS 規(guī)范中沒有任何內(nèi)容限制選擇器的使用，receiveNoWait因此我希望它可以在任何兼容的實(shí)現(xiàn)中工作。
楊魅力
TA貢獻(xiàn)1811條經(jīng)驗(yàn) 獲得超6個(gè)贊
receive()、receive(long timeout) 和 receiveNoWait() 在交付內(nèi)容方面應(yīng)該完全相同。事實(shí)上，有幾個(gè)實(shí)現(xiàn)是通過調(diào)用另一種方法來實(shí)現(xiàn)的。
添加回答
舉報(bào)
0/150
提交
取消