servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ff...@apache.org
Subject svn commit: r702802 - /servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Date Wed, 08 Oct 2008 10:46:34 GMT
Author: ffang
Date: Wed Oct  8 03:46:33 2008
New Revision: 702802

URL: http://svn.apache.org/viewvc?rev=702802&view=rev
Log:
[SM-1621]New JMS in/out provider should support temporary queues/topics (as reply destinations)

Modified:
    servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java

Modified: servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java?rev=702802&r1=702801&r2=702802&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
(original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Wed Oct  8 03:46:33 2008
@@ -23,6 +23,7 @@
 import javax.jms.Destination;
 import javax.jms.JMSException;
 import javax.jms.Message;
+import javax.jms.Queue;
 import javax.jms.Session;
 
 import org.apache.servicemix.common.endpoints.ProviderEndpoint;
@@ -462,6 +463,14 @@
                                                               (String) dest, 
                                                               isPubSubDomain());
         }
+        //create temp queue/topic if no destination explicitly set
+        if (dest == null) {
+            if (destination instanceof Queue) {
+                return session.createTemporaryQueue();
+            } else {
+                return session.createTemporaryTopic();
+            }
+        }
         throw new IllegalStateException("Unable to choose replyDestination for exchange "
+ exchange);
     }
     



Mime
View raw message