Get queues depth from java code

Question

Can anyone help in doing the code in java of getting the depth of the queues. We are having 4 queues in IBM WebSphere MQ and inside them there are messages.

I want to write a jsp to read the queue names and their depth while running the report. How do I do that? Can anyone help in getting the full solution because I don't know what to do

[Same question there ?][1] [1]: stackoverflow.com/questions/8656245/check-mq-queue-depth/… — bdurand
– bdurand, Commented Dec 28, 2011 at 20:45

Aravind Yarram · Accepted Answer · 2011-12-28 20:43:46Z

4

I doens't think there is a way to retrieve the queue depth using JMS. You can however use MQ Series specific Java API to retrieve this information. Here is the sample code. Pay attention to int openOptions = MQC.MQOO_INQUIRE;

Here is the reference guide

int depth = 0;
MQQueueManager qMgr; // define a queue manager object
String mqHost = "";
String mqPort = "";
String mqChannel = "";
String mqQMgr = "";
String mqQueue = "";
try {
    // Set up MQSeries environment
   MQEnvironment.hostname = mqHost;
   MQEnvironment.port = Integer.valueOf(mqPort).intValue();
   MQEnvironment.channel = mqChannel;
   MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
   MQC.TRANSPORT_MQSERIES);
   qMgr = new MQQueueManager(mqQMgr);
   int openOptions = MQC.MQOO_INQUIRE;
   MQQueue destQueue = qMgr.accessQueue(mqQueue, openOptions);
   depth = destQueue.getCurrentDepth();
   destQueue.close();
   qMgr.disconnect();
} catch (Exception err) {
   err.printStackTrace();
}

answered Dec 28, 2011 at 20:43

Aravind Yarram

80.5k49 gold badges239 silver badges335 bronze badges

Sign up to request clarification or add additional context in comments.

4 Comments

user1080320 Over a year ago

Thanks Pangea. Do I have to configure the queue configurations and save your code as .java and run it? or should I do something else?

Aravind Yarram Over a year ago

@user1080320 download the library for the MQ Java api, put it in the classpath and run this code. Most probably the Queue might allow INQUIRY access but sometimes I believe this might be disabled on production queues or restricted only few admin users. Also, Upvote and accept the answer if this helped you.

user1080320 Over a year ago

Pangea, your topic is very helpful but where I can get the MQ Java Api and what is it? in which classpath?

Aravind Yarram Over a year ago

@user1080320 follow this documentation and post on their forums to find where to download from publib.boulder.ibm.com/infocenter/wmqv6/v6r0/…

T.Rob · Accepted Answer · 2012-01-03 16:44:21Z

If you install the WMQ client from the IBM download (as opposed to just grabbing the class libs from the QMgr installation) you get sample code. Among the samples provided are several that list queue names, inquire on object properties and create objects. In a default installation on Win 7 these can be found at C:\Program Files (x86)\IBM\WebSphere MQ\tools\pcf\samples.

Download the WMQ client libraries here:

WMQ v6.0 is SupportPac MQC6 (End of life is September 2012)
WMQ v7.0 is SupportPac MQC7
WMQ v7.1 is SupportPac MQC71
The SupportPac landing page is here.

You are STRONGLY encouraged to use the latest WMQ client for any new development. It will work for all prior versions of WMQ at whatever level of functionality is provided by the target QMgr. Please see the Compatibility & Interop statement in the Infocenter. You can find the Infocenter for the WMQ version of server or client that you are using from the WMQ Library landing page.

Vishal Chhodwani · Accepted Answer · 2018-03-15 10:42:49Z

A few of these functions are depreciated in IIB, so am pasting the updated code. It works :)

Enjoy

Getting MQ Queue Depth From Java:

try {
        int depth = 0;
        MQQueueManager qMgr; // define a queue manager object
        String mqHost = "";
        String mqPort = "";
        String mqChannel = "";
        String mqQMgr = "";
        String mqQueue = "";
        try {
            // Set up MQSeries environment
           MQEnvironment.hostname = mqHost;
           MQEnvironment.port = Integer.valueOf(mqPort).intValue();
           MQEnvironment.channel = mqChannel;
           //MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES);
           qMgr = new MQQueueManager(mqQMgr);
           //int openOptions = 1;//MQC.MQOO_INQUIRE;



           int openOptions = CMQC.MQOO_INQUIRE + CMQC.MQOO_FAIL_IF_QUIESCING + CMQC.MQOO_INPUT_SHARED;


           MQQueue destQueue = qMgr.accessQueue(mqQueue, openOptions);
           depth = destQueue.getCurrentDepth();
           destQueue.close();
           qMgr.disconnect();


            MbMessage outMessage = new MbMessage();
            outAssembly = new MbMessageAssembly(inAssembly, outMessage);
            MbElement root = outMessage.getRootElement();
            MbElement outXmlRoot =  root.createElementAsLastChild(MbXMLNSC.PARSER_NAME);
            MbElement Appointment = outXmlRoot.createElementAsLastChild(MbElement.TYPE_NAME, "RootElementXMLName", null);
            Appointment.createElementAsLastChild(MbElement.TYPE_NAME_VALUE, "Q_DepthFromServer", depth);        
            out.propagate(outAssembly);    
        }

Collectives™ on Stack Overflow

Get queues depth from java code

3 Answers 3

4 Comments

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

3 Answers 3

4 Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related