[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