You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2008/10/08 12:46:34 UTC
svn commit: r702802 -
/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
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);
}