Author: asankha
Date: Thu Nov 1 23:48:36 2007
New Revision: 591243
URL: http://svn.apache.org/viewvc?rev=591243&view=rev
Log:
make sample client JMS 1.0.x compatible too
Modified:
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSUtils.java
Modified:
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java?rev=591243&r1=591242&r2=591243&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java
(original)
+++
webservices/synapse/trunk/java/modules/samples/src/main/java/samples/userguide/GenericJMSClient.java
Thu Nov 1 23:48:36 2007
@@ -19,6 +19,8 @@
package samples.userguide;
+import org.apache.synapse.transport.jms.JMSUtils;
+
import javax.jms.*;
import javax.naming.InitialContext;
import javax.naming.NamingException;
@@ -67,25 +69,23 @@
private void sendBytesMessage(String destName, byte[] payload) throws
Exception {
InitialContext ic = getInitialContext();
ConnectionFactory confac = (ConnectionFactory)
ic.lookup("ConnectionFactory");
- Connection connection = confac.createConnection();
- Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- MessageProducer producer = session.createProducer((Destination)
ic.lookup(destName));
+ Connection connection = JMSUtils.createConnection(confac, null, null);
+ Session session = JMSUtils.createSession(connection, false,
Session.AUTO_ACKNOWLEDGE);
BytesMessage bm = session.createBytesMessage();
bm.writeBytes(payload);
- producer.send(bm);
+ JMSUtils.sendMessageToJMSDestination(session, (Destination)
ic.lookup(destName), bm);
connection.close();
}
private void sendTextMessage(String destName, String payload) throws
Exception {
InitialContext ic = getInitialContext();
ConnectionFactory confac = (ConnectionFactory)
ic.lookup("ConnectionFactory");
- Connection connection = confac.createConnection();
- Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- MessageProducer producer = session.createProducer((Destination)
ic.lookup(destName));
+ Connection connection = JMSUtils.createConnection(confac, null, null);
+ Session session = JMSUtils.createSession(connection, false,
Session.AUTO_ACKNOWLEDGE);
TextMessage tm = session.createTextMessage(payload);
- producer.send(tm);
+ JMSUtils.sendMessageToJMSDestination(session, (Destination)
ic.lookup(destName), tm);
connection.close();
}
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSUtils.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSUtils.java?rev=591243&r1=591242&r2=591243&view=diff
==============================================================================
---
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSUtils.java
(original)
+++
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSUtils.java
Thu Nov 1 23:48:36 2007
@@ -652,6 +652,24 @@
}
// ----------- JMS 1.0.2b compatibility methods -------------
+ public static Connection createConnection(
+ ConnectionFactory conFactory, String user, String pass) throws
JMSException {
+
+ if (conFactory instanceof QueueConnectionFactory) {
+ if (user != null && pass != null) {
+ return ((QueueConnectionFactory)
conFactory).createQueueConnection(user, pass);
+ } else {
+ return ((QueueConnectionFactory)
conFactory).createQueueConnection();
+ }
+ } else {
+ if (user != null && pass != null) {
+ return ((TopicConnectionFactory)
conFactory).createTopicConnection(user, pass);
+ } else {
+ return ((TopicConnectionFactory)
conFactory).createTopicConnection();
+ }
+ }
+ }
+
public static Session createSession(Connection con,
boolean transacted, int acknowledgeMode) throws JMSException {
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
