Author: ruwan Date: Mon May 11 12:20:17 2009 New Revision: 35517 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=35517
Log: sync up with the synapse trunk Modified: branches/synapse/1.3-wso2v1/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java branches/synapse/1.3-wso2v1/modules/samples/src/main/scripts/axis2Client/build.xml branches/synapse/1.3-wso2v1/src/site/xdoc/Synapse_Samples.xml Modified: branches/synapse/1.3-wso2v1/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java?rev=35517&r1=35516&r2=35517&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java (original) +++ branches/synapse/1.3-wso2v1/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java Mon May 11 12:20:17 2009 @@ -19,22 +19,18 @@ package samples.userguide; -import javax.jms.BytesMessage; -import javax.jms.Queue; -import javax.jms.QueueConnection; -import javax.jms.QueueConnectionFactory; -import javax.jms.QueueSender; -import javax.jms.QueueSession; -import javax.jms.TextMessage; +import javax.jms.*; import javax.naming.InitialContext; -import javax.naming.NamingException; -import java.util.Properties; import java.io.File; import java.io.FileInputStream; -import java.io.InputStream; import java.io.IOException; +import java.io.InputStream; +import java.util.Properties; public class GenericJMSClient { + private QueueConnection connection; + private QueueSession session; + private QueueSender sender; private static String getProperty(String name, String def) { String result = System.getProperty(name); @@ -50,54 +46,37 @@ String type = getProperty("jms_type", "text"); String param = getProperty("jms_payload", getRandom(100, 0.9, true) + " " + (int) getRandom(10000, 1.0, true) + " IBM"); + String sMsgCount = getProperty("jms_msgcount", null); GenericJMSClient app = new GenericJMSClient(); + int msgCount = sMsgCount == null ? 1 : Integer.parseInt(sMsgCount); + app.connect(dest); if ("text".equalsIgnoreCase(type)) { - app.sendTextMessage(dest, param); + for (int i=0; i<msgCount; i++) { + app.sendTextMessage(param); + } } else if ("binary".equalsIgnoreCase(type)) { - app.sendBytesMessage(dest, getBytesFromFile(param)); + for (int i=0; i<msgCount; i++) { + app.sendBytesMessage(getBytesFromFile(param)); + } } else if ("pox".equalsIgnoreCase(type)) { - app.sendTextMessage(dest, - "<m:placeOrder xmlns:m=\"http://services.samples\";>\n" + - " <m:order>\n" + - " <m:price>" + getRandom(100, 0.9, true) + "</m:price>\n" + - " <m:quantity>" + (int) getRandom(10000, 1.0, true) + "</m:quantity>\n" + - " <m:symbol>" + param + "</m:symbol>\n" + - " </m:order>\n" + - "</m:placeOrder>"); + for (int i=0; i<msgCount; i++) { + app.sendTextMessage( + "<m:placeOrder xmlns:m=\"http://services.samples\";>\n" + + " <m:order>\n" + + " <m:price>" + getRandom(100, 0.9, true) + "</m:price>\n" + + " <m:quantity>" + (int) getRandom(10000, 1.0, true) + "</m:quantity>\n" + + " <m:symbol>" + param + "</m:symbol>\n" + + " </m:order>\n" + + "</m:placeOrder>"); + } } else { System.out.println("Unknown JMS message type"); } + app.shutdown(); } - private void sendBytesMessage(String destName, byte[] payload) throws Exception { - InitialContext ic = getInitialContext(); - QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory"); - QueueConnection connection = confac.createQueueConnection(); - QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); - BytesMessage bm = session.createBytesMessage(); - bm.writeBytes(payload); - QueueSender sender = session.createSender((Queue)ic.lookup(destName)); - sender.send(bm); - sender.close(); - session.close(); - connection.close(); - } - - private void sendTextMessage(String destName, String payload) throws Exception { - InitialContext ic = getInitialContext(); - QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory"); - QueueConnection connection = confac.createQueueConnection(); - QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); - TextMessage tm = session.createTextMessage(payload); - QueueSender sender = session.createSender((Queue)ic.lookup(destName)); - sender.send(tm); - sender.close(); - session.close(); - connection.close(); - } - - private InitialContext getInitialContext() throws NamingException { + private void connect(String destName) throws Exception { Properties env = new Properties(); if (System.getProperty("java.naming.provider.url") == null) { env.put("java.naming.provider.url", "tcp://localhost:61616"); @@ -106,7 +85,28 @@ env.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); } - return new InitialContext(env); + InitialContext ic = new InitialContext(env); + QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory"); + connection = confac.createQueueConnection(); + session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); + sender = session.createSender((Queue)ic.lookup(destName)); + } + + private void shutdown() throws Exception { + sender.close(); + session.close(); + connection.close(); + } + + private void sendBytesMessage(byte[] payload) throws Exception { + BytesMessage bm = session.createBytesMessage(); + bm.writeBytes(payload); + sender.send(bm); + } + + private void sendTextMessage(String payload) throws Exception { + TextMessage tm = session.createTextMessage(payload); + sender.send(tm); } public static byte[] getBytesFromFile(String fileName) throws IOException { Modified: branches/synapse/1.3-wso2v1/modules/samples/src/main/scripts/axis2Client/build.xml URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/samples/src/main/scripts/axis2Client/build.xml?rev=35517&r1=35516&r2=35517&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/samples/src/main/scripts/axis2Client/build.xml (original) +++ branches/synapse/1.3-wso2v1/modules/samples/src/main/scripts/axis2Client/build.xml Mon May 11 12:20:17 2009 @@ -54,6 +54,8 @@ ant jmsclient [-Djms_type=pox] [-Djms_dest=dynamicQueues/JMSPoxProxy] [-Djms_payload=MSFT] ant jmsclient [-Djms_type=binary] [-Djms_dest=dynamicQueues/JMSFileUploadProxy] [-Djms_payload=./../../repository/conf/sample/resources/mtom/asf-logo.gif] + ant jmsclient [-Djms_type=pox] [-Djms_dest=dynamicQueues/JMSPoxProxy] [-Djms_payload=MSFT] + [-Djms_msgcount=10000] ant optimizeclient A client that could send binary content using MTOM and SwA optimizations @@ -128,6 +130,7 @@ <property name="jms_dest" value=""/> <property name="jms_type" value=""/> <property name="jms_payload" value=""/> + <property name="jms_msgcount" value=""/> <property name="opt_mode" value=""/> <property name="opt_url" value=""/> <property name="opt_file" value=""/> @@ -223,6 +226,7 @@ <sysproperty key="jms_dest" value="${jms_dest}"/> <sysproperty key="jms_type" value="${jms_type}"/> <sysproperty key="jms_payload" value="${jms_payload}"/> + <sysproperty key="jms_msgcount" value="${jms_msgcount}"/> <sysproperty key="java.io.tmpdir" value="./../../work/temp/sampleClient"/> </java> </target> Modified: branches/synapse/1.3-wso2v1/src/site/xdoc/Synapse_Samples.xml URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/src/site/xdoc/Synapse_Samples.xml?rev=35517&r1=35516&r2=35517&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/src/site/xdoc/Synapse_Samples.xml (original) +++ branches/synapse/1.3-wso2v1/src/site/xdoc/Synapse_Samples.xml Mon May 11 12:20:17 2009 @@ -2322,6 +2322,7 @@ <outSequence> <property name="transport.vfs.ReplyFileName" expression="fn:concat(fn:substring-after(get-property('MessageID'), 'urn:uuid:'), '.xml')" scope="transport"/> + <property action="set" name="OUT_ONLY" value="true"/> <send> <endpoint> <address uri="vfs:file:///home/user/test/out"/> <!--CHANGE--> _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
