我如何获取带有远程Websphere应用程序服务器中所有队列名称的列表？

debugcn 发表于 Dev

胜利者

我使用AdminClient连接到远程服务器，并使用一些代码获取队列列表：

...
AdminClient client = new AdminClientFactory.createAdminClient(props);
Set<ObjectName> s = client.queryNames(new ObjectName("WebSphere:*"),null);
if (!s.isEmpty()){
     Iterator i = s.iterator();
     while (i.hasNext){
          ObjectName on = i.next();
          String type = on.getKeyProperty("type");
          if ("SIBQueuePoint".eqquals(type)){
               System.out.println(on.getKeyProperty("name");)
          }
     }
}

此列表列出了我与JMS提供程序“默认消息提供程序”的队列。而且，我还有一些“ Websphere MQ消息传递提供程序”队列，在此列表中不存在。

我如何从所有JMS提供程序获取所有队列的列表？

adimoise91

抱歉，迟到了。我保证，这是python语言的脚本。

您所要做的就是替换您的范围和您的资源文件。

import sys, java, java.io, java.lang

lineSeparator = java.lang.System.getProperty('line.separator')

def listMQQCF(scope):
    scopeID = AdminConfig.getid(scope)
    scopeName = scope[scope.rfind(":")+1:scope.rfind("/")]
    wmqQCFList = AdminConfig.list('MQQueueConnectionFactory', scopeID).split(lineSeparator)
    MQQCFListHeader = "\n#==== MQQueueConnectionFactoryList " + scopeName + " ===="
    MQQCFListHeader = MQQCFListHeader + "\n#[name, jndiName, ,description, queueManager, transportType, host, port, channel, ConmaxConn, ConminCon, SessionmaxConn, SessionminConn]\n"  
    MQQCFList = "MQQueueConnectionFactoryList = [\\\n"
    if (len(wmqQCFList) > 0):
        for wmqQCF in wmqQCFList:
            wmqQCFName = wmqQCF[wmqQCF.rfind("/")+1:wmqQCF.find("|")]
            if (scopeName == wmqQCFName):
                name = AdminConfig.showAttribute(wmqQCF, 'name')
                jndiName = AdminConfig.showAttribute(wmqQCF, 'jndiName')
                description = AdminConfig.showAttribute(wmqQCF, 'description')
                if (description == None): description = ""
                queueManager = AdminConfig.showAttribute(wmqQCF, 'queueManager')                
                transportType = AdminConfig.showAttribute(wmqQCF, 'transportType')
                host = AdminConfig.showAttribute(wmqQCF, 'host')
                port = AdminConfig.showAttribute(wmqQCF, 'port')
                channel = AdminConfig.showAttribute(wmqQCF, 'channel')
                connPool = AdminConfig.showAttribute(wmqQCF, 'connectionPool')
                sessionPool = AdminConfig.showAttribute(wmqQCF, 'sessionPool')
                connTimeout = AdminConfig.showAttribute(connPool, "connectionTimeout")
                maxConn = AdminConfig.showAttribute(connPool, "maxConnections")
                minConn = AdminConfig.showAttribute(connPool, "minConnections")
                reapTime = AdminConfig.showAttribute(connPool, "reapTime")
                unusedTimeout =  AdminConfig.showAttribute(connPool, "unusedTimeout")
                agedTimeout = AdminConfig.showAttribute(connPool, "agedTimeout")
                sesconnTimeout = AdminConfig.showAttribute(sessionPool, "connectionTimeout")
                sesmaxConn = AdminConfig.showAttribute(sessionPool, "maxConnections")
                sesminConn = AdminConfig.showAttribute(sessionPool, "minConnections")
                sesreapTime = AdminConfig.showAttribute(sessionPool, "reapTime")
                sesunusedTimeout =  AdminConfig.showAttribute(sessionPool, "unusedTimeout")
                sesagedTimeout = AdminConfig.showAttribute(sessionPool, "agedTimeout")
                MQQCFList = MQQCFList + "['" + name + "','" + jndiName + "','" + description + "','" +  queueManager + "','" + transportType + "','" + host + "','" + port + "','" + channel + "','" + maxConn + "','" + minConn + "','" + sesmaxConn + "','" + sesminConn + "'],\\\n"
    if (MQQCFList[len(MQQCFList)-3] == ","):
        MQQCFList = MQQCFList[0:len(MQQCFList)-3] + "]\n"
    else:
        MQQCFList = MQQCFList[0:len(MQQCFList)-2] + "]\n"
    return MQQCFListHeader + MQQCFList

def listMQQueue(scope):
    scopeID = AdminConfig.getid(scope)
    scopeName = scope[scope.rfind(":")+1:scope.rfind("/")]
    objdmgr = AdminControl.queryNames('WebSphere:type=Server,name=dmgr,*')
    version = objdmgr[objdmgr.find("version")+8:]
    wmqQueueList = AdminConfig.list('MQQueue', scopeID).split(lineSeparator)
    MQQueueListHeader = "\n#==== MQQueueList " + scopeName + "  ====\n#[name, jndiName, description, baseQueueName, baseQMgrName, persistence, priority, targetClient, messageBody]\n"
    MQQueueList = "MQQueueList = [\\\n"
    if (len(wmqQueueList) > 0) :
        for wmqQueue in wmqQueueList:
            wmqQueueName = wmqQueue[wmqQueue.rfind("/")+1:wmqQueue.find("|")]
            if (scopeName == wmqQueueName):
                name = AdminConfig.showAttribute(wmqQueue, 'name')
                jndiName = AdminConfig.showAttribute(wmqQueue, 'jndiName')
                description = AdminConfig.showAttribute(wmqQueue, 'description')
                if (description == None):   description = ""
                baseQueueName = AdminConfig.showAttribute(wmqQueue, 'baseQueueName')
                baseQMgrName = AdminConfig.showAttribute(wmqQueue, 'baseQueueManagerName')
                if (baseQMgrName == None):  baseQMgrName = ""
                persistence = AdminConfig.showAttribute(wmqQueue, 'persistence')    
                priority = AdminConfig.showAttribute(wmqQueue, 'priority')
                targetClient = AdminConfig.showAttribute(wmqQueue, 'targetClient')
                if (version =='8'):
                    messageBody = AdminConfig.showAttribute(wmqQueue, 'messageBody')
                else:
                    messageBody = ""                
                MQQueueList = MQQueueList + "['" + name + "','" + jndiName + "','" + description + "','" + baseQueueName + "','" + baseQMgrName + "','" + persistence + "','" + priority + "','" + targetClient + "','" + messageBody + "'],\\\n"               
            #endif
    if (MQQueueList[len(MQQueueList)-3] == ","):
        MQQueueList = MQQueueList[0:len(MQQueueList)-3] + "]\n"
    else:
        MQQueueList = MQQueueList[0:len(MQQueueList)-2] + "]\n"
    return MQQueueListHeader + MQQueueList


#===============================================
#MAIN
#===============================================    

filename='resources.txt'
scope='/Cell:CellName/ServerCluster:ClusterName/'


objItemFileOutputStream = java.io.FileOutputStream(fileName, 1)
scopeID = AdminConfig.getid(scope)
if ( scopeID <> ""):
    list = listRes(objType, scope)
    objItemFileOutputStream.write(list)
else:
    print "\n" + scope + "\t Failed: Incorrect scopes!\n"
objItemFileOutputStream.close()

祝你好运！

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。