[jboss-svn-commits] JBL Code SVN: r8214 - labs/jbossesb/trunk/product/samples/trailblazer2/banks/src/org/jboss/soa/esb/samples/loanbroker/banks

[jboss-svn-commits at lists.jboss.org]

Author: kurt.stam at jboss.com
Date: 2006-12-11 00:13:17 -0500 (Mon, 11 Dec 2006)
New Revision: 8214

Modified:
   labs/jbossesb/trunk/product/samples/trailblazer2/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/ManagerJMS.java
Log:
validating again MQ 5.3 and 6.0

Modified: labs/jbossesb/trunk/product/samples/trailblazer2/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/ManagerJMS.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/ManagerJMS.java	2006-12-11 05:11:57 UTC (rev 8213)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/banks/src/org/jboss/soa/esb/samples/loanbroker/banks/ManagerJMS.java	2006-12-11 05:13:17 UTC (rev 8214)
@@ -36,6 +36,7 @@
 import javax.jms.TextMessage;
 import javax.naming.Context;
 import javax.naming.InitialContext;
+import javax.naming.NamingException;
 
 import org.apache.log4j.Logger;
 import org.apache.log4j.Priority;
@@ -76,6 +77,9 @@
 	 */
 	public void listen() {
 		try {
+			//MQ Series
+			//properties.put(Context.INITIAL_CONTEXT_FACTORY,"com.ibm.mq.jms.context.WMQInitialContextFactory");
+			//properties.put(Context.PROVIDER_URL           , "dev38:1415/SYSTEM.DEF.SVRCONN");
 			//ActiveMQ
 			//properties.put(Context.INITIAL_CONTEXT_FACTORY,"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
 			//properties.put(Context.PROVIDER_URL           , "tcp://localhost:61616");
@@ -93,8 +97,13 @@
 			QueueSession qs = inQueueConnection.createQueueSession(false,
 					Session.DUPS_OK_ACKNOWLEDGE);
 			logger.info("Looking up queue=" + QUEUE_IN);
-			Queue inQueue = qs.createQueue(QUEUE_IN);
-			//Queue inQueue = (Queue) ctx.lookup(QUEUE_IN);
+			Queue inQueue=null;
+			try {
+				inQueue = (Queue) ctx.lookup(QUEUE_IN);
+			} catch (NamingException ne) {
+				inQueue = qs.createQueue(QUEUE_IN);
+			}
+			//Queue 
 			QueueReceiver qr = qs.createReceiver(inQueue);
 			qr.setMessageListener(this);
 			inQueueConnection.start();