[jboss-svn-commits] JBL Code SVN: r11465 - in labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart: transformedi2xmlgroovy and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sun Apr 29 14:23:21 EDT 2007
Author: sebcao
Date: 2007-04-29 14:23:20 -0400 (Sun, 29 Apr 2007)
New Revision: 11465
Added:
labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/
labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/test/
labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/test/SendJMSMessage.java
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/SendJMSMessage.java
Log:
JBESB-403
Copied: labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy (from rev 11423, labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/quickstart/helloworld/test)
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/quickstart/helloworld/test/SendJMSMessage.java 2007-04-27 19:24:49 UTC (rev 11423)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/SendJMSMessage.java 2007-04-29 18:23:20 UTC (rev 11465)
@@ -1,93 +0,0 @@
-/*
- * 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 quickstart.helloworld.test;
-
-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;
-
-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
Added: labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/test/SendJMSMessage.java (rev 0)
+++ labs/jbossesb/trunk/product/samples/quickstarts/transform_EDI2XML_Groovy_XSLT/src/org/jboss/soa/esb/samples/quickstart/transformedi2xmlgroovy/test/SendJMSMessage.java 2007-04-29 18:23:20 UTC (rev 11465)
@@ -0,0 +1,93 @@
+/*
+ * 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.test;
+
+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;
+
+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
More information about the jboss-svn-commits
mailing list