You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-commits@axis.apache.org by sa...@apache.org on 2012/03/06 12:17:18 UTC

svn commit: r1297425 - in /axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms: JMSEndpoint.java JMSUtils.java

Author: sagara
Date: Tue Mar  6 11:17:18 2012
New Revision: 1297425

URL: http://svn.apache.org/viewvc?rev=1297425&view=rev
Log:
Applied patch for TRANSPORTS-16.

Modified:
    axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSEndpoint.java
    axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java

Modified: axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSEndpoint.java
URL: http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSEndpoint.java?rev=1297425&r1=1297424&r2=1297425&view=diff
==============================================================================
--- axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSEndpoint.java (original)
+++ axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSEndpoint.java Tue Mar  6 11:17:18 2012
@@ -228,7 +228,7 @@ public class JMSEndpoint extends Protoco
             }
         } else {
             log.debug("JMS reply destination type not given. default queue");
-            destinationType = JMSConstants.QUEUE;
+            replyDestinationType = JMSConstants.DESTINATION_TYPE_QUEUE;
         }
         
         jndiReplyDestinationName = ParamUtils.getOptionalParam(service,

Modified: axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java
URL: http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java?rev=1297425&r1=1297424&r2=1297425&view=diff
==============================================================================
--- axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java (original)
+++ axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/JMSUtils.java Tue Mar  6 11:17:18 2012
@@ -709,7 +709,7 @@ public class JMSUtils extends BaseUtils 
         } catch (NameNotFoundException e) {
             try {
                 return JMSUtils.lookup(context, Destination.class,
-                    (JMSConstants.DESTINATION_TYPE_TOPIC.equals(destinationType) ?
+                    (JMSConstants.DESTINATION_TYPE_TOPIC.equalsIgnoreCase(destinationType) ?
                         "dynamicTopics/" : "dynamicQueues/") + destinationName);
             } catch (NamingException x) {
                 log.warn("Cannot locate destination : " + destinationName);