llgd.net
当前位置:首页 >> 用jAvA接口怎么取MQ队列深度 >>

用jAvA接口怎么取MQ队列深度

不知道用的是什么Mq框架,如果是IBM的mq,应该可以通过MQMannager的getTotalMessageLength,getMessageLength获取

activemq 只能拿出来遍历,用监听触发局部变量,就可以知道有多少条信息,或者nowait方法 for循环遍历也可以; 你队列的状态指的是什么呢?

{ //前面是准备管理器和队列 MQQueueManager qMgr = new MQQueueManager(qManager); int openOptions = MQConstants.MQOO_INPUT_AS_Q_DEF | MQConstants.MQOO_OUTPUT | MQConstants.MQOO_INQUIRE; MQQueue queue = qMgr.accessQueue(qName, open...

你说的是activemq的话,很遗憾的告诉你,不能

时间片轮询

WebSphere MQ 接收发送 添加mq jar 类介绍: SendMSG:消息发送类。 Main():主方法。 SendMSG():消息发送方法。 方法描述: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 package test; public cla...

下面是RabbitMQ的消息确认机制:“为了确保消息不会丢失,RabbitMQ支持消息确认机制。客户端在接受到消息并处理完后,可以发送一个ack消息给RabbitMQ,告诉它该消息可以安全的删除了。假如客户端在发送ack之前意外死掉了,那么RabbitMQ会将消息投...

MQException 该类包含WebSphere MQ 完成代码和错误代码常量的定义。以MQCC_开始的常量是WebSphere MQ 完成代码,而以MQRC_开始的常量则是WebSphere MQ 原因代码。只要出现WebSphere MQ 错误,就会给出MQException。 MQGetMessageOptions 该类包...

你用的是IBM MQ还是Apache的? 一般通过JAVA的JMS可以取得。 例如IBM MQ里有个MQQueue 对象 // 获取队列实例 MQQueue queue = qMgr.accessQueue("TEST_QUEUE", openOptions); //获取当前队列最长消息的长度 queue.getMaximumMessageLength() //...

不是通过线程实现的,它是通过一种注册--通知机制实现的。在java的设计模式中,有一种模式叫:观察者模式,和这个类似。举个例子,本例子是一个简单的监听当数据发生变化时要做的操作。 1,我们先定义一个接口,可以让多个监听者实现public inte...

网站首页 | 网站地图
All rights reserved Powered by www.llgd.net
copyright ©right 2010-2021。
内容来自网络,如有侵犯请联系客服。zhit325@qq.com