Discussion :

[TslH0]

Bonjour,

Je suis tout nouveau dans l'univers de Websphere MQ. Je tente de reproduire un espèce d'Explorateur de files d'attentes, et pour cela je cherche un moyen de lister les files d'attentes d'un MQQueueManager. Malheureusement, je ne trouve rien me permettant de les lister :-/

Quelqu'un pourrait-il m'aider s'il vous plaît?

Merci par avance.

[java_fun]

Bonjour,

Pour lister les queues du MQ il faut utiliser l’api suivant : com.ibm.mq.pcf
Champs requis : le nom du manager.
Champs optionnel : préfixe des queues sous le manager
Voici un exemple de code avec deux méthodes une qui liste les queues, et une qui donne le statut (nombre de messages stockés dans la queue)

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
31
32
33
 
public static Vector ListQueueNames() {
 
logger.debug("ListQueueNames -->");
 
Vector Listq = new Vector();
PCFAgent agent;
PCFParameter[] parameters = { new MQCFST(CMQC.MQCA_Q_NAME, "*"),
				new MQCFIN(CMQC.MQIA_Q_TYPE, CMQC.MQQT_LOCAL) };
MQMessage[] responses;
MQCFH cfh;
MQCFSL cfsl;
 
try {
        agent = new PCFAgent(mqManager); // mqManager nom du manager
        responses = agent.send(CMQCFC.MQCMD_INQUIRE_Q_NAMES, parameters);
        cfh = new MQCFH(responses[0]);
 
        if (cfh.reason == 0) {
          cfsl = new MQCFSL(responses[0]);
          for (int i = 0; i < cfsl.strings.length; i++) {
              // on récup içi que du queues qui commence par prefixeMQ 
	if (cfsl.strings[i].startsWith(prefixeMQ)) { 
	    Listq.add(cfsl.strings[i]);
	  }
	}
	}
     } catch (Exception e) {
	logger.error("ListQueueNames - Exception while getting queues list : ",e);
}
		logger.debug("ListQueueNames <--");
		return Listq;
}

la méthode qui donne le statut

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
public static Map MQ_State(Vector ListQueues) {
 
		logger.debug("MQ_State -->");
 
		Map mqState = new HashMap();
		try {
			MQQueueManager qm = new MQQueueManager(mqManager);
			for (int i = 0; i < ListQueues.size(); i++) {
				MQQueue queue = qm.accessQueue(ListQueues.get(i).toString(),
						MQC.MQOO_BROWSE | MQC.MQOO_FAIL_IF_QUIESCING
								| MQC.MQOO_INQUIRE | MQC.MQOO_INPUT_SHARED);
				mqState.put(queue.name.trim(), new Integer(queue
						.getCurrentDepth()));
				if (logger.isInfoEnabled())
					logger.info("MQ_State - queue :" + queue.name.trim()
							+ " with " + queue.getCurrentDepth() + " messages");
			}
		} catch (MQException e) {
			logger.error("MQ_State - Exception while accessing queues : ", e);
		}
		logger.debug("MQ_State -->");
		return mqState;
	}

Cordialement