我是消息代理的新手，我遇到了问题。
我需要做的是这个。检查消息队列。如果消息队列已备份，我需要每 7 秒一次释放一条消息。不知道从哪里开始。
问问题
362 次
1 回答
0
在这里释放是什么意思？您只是想使用该消息还是将其放入某种故障队列？
假设是这种情况，您可以使用 Timeout Control 节点的组合来每 7 秒驱动一次流，并使用 MQGET 节点来使用消息（并且可以选择连接 MQOutput 节点以将消息放入不同的队列）。
棘手的部分将是确定队列是否已备份，我将使用 Java 计算节点并使用 MQ Java Base API 使用 PCF 进行调用以检查队列深度。
如果队列深度高于某个阈值，则该流将仅传播到 MQGET 节点。
您可以从 API 文档中获取有关使用 PCF 类的更多信息：
于 2013-09-19T16:38:21.420 回答