Author: sagara
Date: Tue Mar 6 12:37:32 2012
New Revision: 1297451
URL: http://svn.apache.org/viewvc?rev=1297451&view=rev
Log:
Applied patch for TRANSPORTS-48.
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSOutTransportInfo.java
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSOutTransportInfo.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSOutTransportInfo.java?rev=1297451&r1=1297450&r2=1297451&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSOutTransportInfo.java
(original)
+++
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSOutTransportInfo.java
Tue Mar 6 12:37:32 2012
@@ -332,8 +332,12 @@ public class JMSOutTransportInfo impleme
} else if
(JMSConstants.DESTINATION_TYPE_TOPIC.equals(destinationType)) {
destType = JMSConstants.TOPIC;
tConFac = (TopicConnectionFactory) connectionFactory;
- }
-
+ } else{
+ //treat jmsdestination type=queue(default is queue)
+ destType = JMSConstants.QUEUE;
+ qConFac = (QueueConnectionFactory) connectionFactory;
+ }
+
Connection connection = null;
if (user != null && pass != null) {
if (qConFac != null) {
