[jboss-svn-commits] JBL Code SVN: r8511 - labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Thu Dec 21 12:59:53 EST 2006
Author: burrsutter
Date: 2006-12-21 12:59:52 -0500 (Thu, 21 Dec 2006)
New Revision: 8511
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/ReturnJMSMessage.java
Log:
not needed in this example
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/ReturnJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/ReturnJMSMessage.java 2006-12-21 17:52:52 UTC (rev 8510)
+++ labs/jbossesb/trunk/product/samples/quickstarts/more_action/src/quickstart/ReturnJMSMessage.java 2006-12-21 17:59:52 UTC (rev 8511)
@@ -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