[jboss-svn-commits] JBL Code SVN: r11476 - in labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart: transformedi2xmlgroovyxslt and 1 other directories.

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

Author: sebcao
Date: 2007-04-29 15:25:45 -0400 (Sun, 29 Apr 2007)
New Revision: 11476

Added:
   labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/
   labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/test/
   labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/test/SendJMSMessage.java
Log:
JBESB-403

Added: labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/test/SendJMSMessage.java	                        (rev 0)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovyxslt/test/SendJMSMessage.java	2007-04-29 19:25:45 UTC (rev 11476)
@@ -0,0 +1,95 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and others contributors as indicated 
+ * by the @authors tag. All rights reserved. 
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors. 
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A 
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 
+ * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 
+ * MA  02110-1301, USA.
+ * 
+ * (C) 2005-2006,
+ * @author JBoss Inc.
+ */
+package org.jboss.soa.esb.samples.quickstart.transformedi2xmlgroovyxslt;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+
+import javax.jms.JMSException;
+import javax.jms.ObjectMessage;
+import javax.jms.Queue;
+import javax.jms.QueueConnection;
+import javax.jms.QueueConnectionFactory;
+import javax.jms.QueueSender;
+import javax.jms.QueueSession;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+import org.milyn.io.StreamUtils;
+
+import quickstart.helloworld.test.SendJMSMessage;
+
+public class SendJMSMessage {
+    QueueConnection conn;
+    QueueSession session;
+    Queue que;
+    
+    
+    public void setupConnection() throws JMSException, NamingException
+    {
+    	InitialContext iniCtx = new InitialContext();
+    	Object tmp = iniCtx.lookup("ConnectionFactory");
+    	QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
+    	conn = qcf.createQueueConnection();
+    	que = (Queue) iniCtx.lookup("queue/quickstart_edi_groovy_xslt_gw");
+    	session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
+    	conn.start();
+    	System.out.println("Connection Started");
+    }
+    
+    public void stop() throws JMSException 
+    { 
+        conn.stop();
+        session.close();
+        conn.close();
+    }
+    
+    public void sendAMessage(String fileName) throws JMSException, FileNotFoundException, IOException {
+    	
+        QueueSender send = session.createSender(que);
+        ObjectMessage tm;
+        File file = new File(fileName);
+        
+        if(!file.exists()) {
+        	throw new IllegalArgumentException("Input message file [" + file.getAbsolutePath() + "] not found.");
+        }
+        
+        String message = new String(StreamUtils.readStream(new FileInputStream(file)));
+        
+        tm = session.createObjectMessage(message);
+        send.send(tm);        
+        send.close();
+        
+        System.out.println("*** Switch back to the ESB Java console now to see '" + fileName + "' before and after the transformation...");
+    }
+       
+    
+    public static void main(String args[]) throws Exception
+    {        	    	
+    	SendJMSMessage sm = new SendJMSMessage();
+    	sm.setupConnection();
+    	sm.sendAMessage(args[0]); 
+    	sm.stop();
+    }
+    
+}
\ No newline at end of file