[jboss-svn-commits] JBL Code SVN: r7894 - labs/jbossesb/trunk/product/samples/quickstarts/helloworld/src/quickstart
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Nov 28 15:46:56 EST 2006
Author: burrsutter
Date: 2006-11-28 15:46:55 -0500 (Tue, 28 Nov 2006)
New Revision: 7894
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/helloworld/src/quickstart/ReturnJMSMessage.java
Log:
this was pushed up to the wrong folder
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/helloworld/src/quickstart/ReturnJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld/src/quickstart/ReturnJMSMessage.java 2006-11-28 20:40:45 UTC (rev 7893)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld/src/quickstart/ReturnJMSMessage.java 2006-11-28 20:46:55 UTC (rev 7894)
@@ -1,49 +0,0 @@
-package quickstart;
-
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-import javax.jms.JMSException;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.Queue;
-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 org.jboss.soa.esb.message.Message;
-
-public class ReturnJMSMessage {
-
- public static void sendMessage(Message esbMessage,String newDestination) throws JMSException, NamingException, Exception {
- if (esbMessage == null || newDestination == null)
- throw new Exception("Message and JMS Destination are required");
-
- QueueConnection conn;
- QueueSession session;
- Queue que;
-
- InitialContext iniCtx = new InitialContext();
- Object tmp = iniCtx.lookup("ConnectionFactory");
- QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
- conn = qcf.createQueueConnection();
- que = (Queue) iniCtx.lookup("queue/" + newDestination);
- session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
- conn.start();
-
-
- String newMsg = new String(esbMessage.getBody().getContents());
-
-
- QueueSender send = session.createSender(que);
- TextMessage tm = session.createTextMessage(newMsg);
- send.send(tm);
-
-
- conn.stop();
- }
-
-}
\ No newline at end of file
More information about the jboss-svn-commits
mailing list