Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import com.im.imb.transformation.message.*
- import com.ibm.mq.jms.*
- import com.ibm.mq.*
- import javax.jms.*
- import javax.naming.*
- String boostrapUrl = "iiop://192.168.27.115:2811"
- String queueJndi = "queue/DeadLetterQueue"
- def IMNode lookup(bootStrap, queue) {
- Hashtable env= new Hashtable()
- env.put(Context.INITIAL_CONTEXT_FACTORY,"com.ibm.websphere.naming.WsnInitialContextFactory")
- env.put(Context.PROVIDER_URL, bootStrap)
- InitialContext initialContext = new InitialContext(env)
- com.ibm.mq.jms.MQQueue qRef = initialContext.lookup(queue)
- StringTokenizer st = new StringTokenizer(qRef.getQueueName())
- String junk = st.nextToken("/")
- String qMName = st.nextToken("/")
- String qName = st.nextToken("?").substring(1)
- MQQueueManager qMgr = new MQQueueManager(qMName)
- openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT | MQC.MQOO_INQUIRE
- com.ibm.mq.MQQueue q = new com.ibm.mq.MQQueue(qMgr , qName, openOptions , null, null, null)
- qDetail = new IMNode(qName)
- qDetail.put("currentDepth", q.currentDepth)
- qDetail.put("maximumDepth", q.maximumDepth)
- qDetail.put("maximumMessageLength", q.maximumMessageLength)
- qDetail.put("queueType", q.queueType)
- qDetail.put("creationDate", q.creationDateTime.time)
- return qDetail
- }
- queueDetails = lookup(boostrapUrl, queueJndi)
Add Comment
Please, Sign In to add comment