我目前正在從一個(gè)充滿事務(wù)（消息）的遠(yuǎn)程隊(duì)列中讀取數(shù)據(jù)。我通過(guò)訪問(wèn)隊(duì)列和測(cè)量記錄的大小來(lái)閱讀它。getOptions.options = MQC.MQGMO_CONVERT + MQC.MQGMO_WAIT;queue.getCurrentDepth();僅當(dāng)隊(duì)列的大小大于 0 時(shí)。我繼續(xù)獲取消息。我的問(wèn)題是，對(duì)于某些消息，我收到以下錯(cuò)誤：MQJE001：完成代碼“2”，原因“2033”。但僅對(duì)于某些消息，有趣的是我有一個(gè)自定義重試變量，第三次重試得到一條空白消息。我可能的解決方案：起初我以為它可能是 waitInterval，我一直在將它從 150 毫秒更改為 30 秒。對(duì)于某些消息，我在不到 100 毫秒的時(shí)間內(nèi)正確接收了它們。但是給我問(wèn)題的消息占用了所有的waitInterval然后給出錯(cuò)誤并得到空白消息到第三次重試。第二個(gè)測(cè)試是驗(yàn)證 MQMessage 類(lèi)的參數(shù)，我原來(lái)有：消息類(lèi)型：8編碼：273格式：字符集：0當(dāng)我正確收到一條消息時(shí)，以下參數(shù)仍然存在：消息類(lèi)型：8編碼：273格式：MQSTR字符集：819當(dāng)我在第三次重試時(shí)收到導(dǎo)致錯(cuò)誤 2033 的消息時(shí)，我收到一條空白消息并且參數(shù)更改為以下內(nèi)容：消息類(lèi)型：8編碼：273格式：字符集：819我開(kāi)始認(rèn)為隊(duì)列中的消息沒(méi)有指示正確的格式。所以我聯(lián)系了支持人員，他們確認(rèn)所有消息都具有正確的轉(zhuǎn)換標(biāo)頭。所以我仍然懷疑為什么這個(gè)問(wèn)題，如果有人遇到過(guò)類(lèi)似的事情，我會(huì)很感激你的評(píng)論。謝謝。
1 回答
瀟瀟雨雨
TA貢獻(xiàn)1833條經(jīng)驗(yàn) 獲得超4個(gè)贊
您將 IBM MQ 視為數(shù)據(jù)庫(kù)，這會(huì)給您帶來(lái)各種痛苦。
這是您應(yīng)該如何檢索消息：
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = CMQC.MQGMO_WAIT + CMQC.MQGMO_FAIL_IF_QUIESCING;
gmo.waitInterval = 5000; // wait up to 5 seconds
MQMessage receiveMsg = null;
boolean getMore = true;
while(getMore)
{
receiveMsg = new MQMessage();
try
{
// get the message on the queue
queue.get(receiveMsg, gmo);
/*
* Now go do something with the message
*/
}
catch (MQException e)
{
if ( (e.completionCode == CMQC.MQCC_FAILED) &&
(e.reasonCode == CMQC.MQRC_NO_MSG_AVAILABLE) )
{
// No message - loop again
}
else
{
System.out.println("MQException: " + e.getLocalizedMessage());
System.out.println("CC=" + e.completionCode + " : RC=" + e.reasonCode);
getMore = false;
}
}
catch (IOException e)
{
System.out.println("IOException:" +e.getLocalizedMessage());
}
}
添加回答
舉報(bào)
0/150
提交
取消