[jboss-svn-commits] JBL Code SVN: r11626 - labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo.

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

Author: kevin.conner at jboss.com
Date: 2007-05-03 02:28:13 -0400 (Thu, 03 May 2007)
New Revision: 11626

Modified:
   labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/MyJMSListenerAction.java
   labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/ReturnJMSMessage.java
Log:
Allow JNDI config of reply

Modified: labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/MyJMSListenerAction.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/MyJMSListenerAction.java	2007-05-03 06:27:22 UTC (rev 11625)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/MyJMSListenerAction.java	2007-05-03 06:28:13 UTC (rev 11626)
@@ -72,7 +72,7 @@
 		   logHeader();
 		   System.out.println(new String(message.getBody().getContents()));
 		   logFooter();
-		   ReturnJMSMessage.sendMessage(message,"quickstart_simple_transformation_Response");
+		   ReturnJMSMessage.sendMessage(message,"quickstart_simple_transformation_Response",_config);
 	   } catch (Exception e) {
 		   logHeader();
 		   System.out.println(e.getMessage());

Modified: labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/ReturnJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/ReturnJMSMessage.java	2007-05-03 06:27:22 UTC (rev 11625)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_XML2POJO/src/org/jboss/soa/esb/samples/quickstart/transformxml2pojo/ReturnJMSMessage.java	2007-05-03 06:28:13 UTC (rev 11626)
@@ -20,6 +20,7 @@
  */
 package org.jboss.soa.esb.samples.quickstart.transformxml2pojo;
 
+import javax.naming.Context;
 import javax.naming.InitialContext;
 import javax.naming.NamingException;
 import javax.jms.JMSException;
@@ -28,17 +29,17 @@
 import javax.jms.QueueConnection;
 import javax.jms.QueueSession;
 import javax.jms.QueueSender;
-import javax.jms.ObjectMessage;
 import javax.jms.TextMessage;
 
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
+import java.util.Hashtable;
+
+import org.jboss.soa.esb.addressing.eprs.JMSEpr;
+import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.message.Message;
 
 public class ReturnJMSMessage {
        
-    public static void sendMessage(Message esbMessage,String newDestination) throws JMSException, NamingException, Exception {
+    public static void sendMessage(Message esbMessage,String newDestination, final ConfigTree config) throws JMSException, NamingException, Exception {
     	if (esbMessage == null || newDestination == null) 
     		throw new Exception("Message and JMS Destination are required");
     
@@ -46,7 +47,25 @@
         QueueSession session;
         Queue que;
         
-    	InitialContext iniCtx = new InitialContext();
+        final Hashtable<String, String>env = new Hashtable<String, String>();
+        final String providerURL = config.getAttribute(JMSEpr.JNDI_URL_TAG) ;
+        if (providerURL != null)
+        {
+            env.put(Context.PROVIDER_URL, providerURL) ;
+        }
+        final String initialContextFactory = config.getAttribute(JMSEpr.JNDI_CONTEXT_FACTORY_TAG) ;
+        if (initialContextFactory != null)
+        {
+            env.put(Context.INITIAL_CONTEXT_FACTORY, initialContextFactory) ;
+        }
+        
+        final String urlPkgPrefixes = config.getAttribute(JMSEpr.JNDI_PKG_PREFIX_TAG) ;
+        if (urlPkgPrefixes != null)
+        {
+            env.put(Context.URL_PKG_PREFIXES, urlPkgPrefixes) ;
+        }
+        
+    	InitialContext iniCtx = new InitialContext(env);
     	Object tmp = iniCtx.lookup("ConnectionFactory");
     	QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
     	conn = qcf.createQueueConnection();