Correct JMS binding.sca destination create options

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@691961 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 8 insertions, 0 deletions

diff --git a/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java b/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
index 21da1e5e92..87c9098737 100644
--- a/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
+++ b/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
@@ -51,6 +51,13 @@ public class JMSSCABindingProviderFactory implements BindingProviderFactory<Dist
                                                                    RuntimeComponentReference reference,
                                                                    DistributedSCABinding binding) {
         JMSBinding jmsBinding = createBinding(binding);
+
+        // FIXME: CREATE_NEVER doesn't work as the dynamically created JNDI destinations 
+        // aren't replicated around the broker cluster. Maybe it needs an AMQ specific
+        // impl of the Tuscany JMSResourceFactory which uses use physical destinations 
+        // instead of JNDI
+        //jmsBinding.setDestinationCreate(JMSBindingConstants.CREATE_NEVER);
+
         return new JMSBindingReferenceBindingProvider(component, reference, jmsBinding);
     }
 
@@ -58,6 +65,7 @@ public class JMSSCABindingProviderFactory implements BindingProviderFactory<Dist
                                                                RuntimeComponentService service,
                                                                DistributedSCABinding binding) {
         JMSBinding jmsBinding = createBinding(binding);
+        jmsBinding.setDestinationCreate(JMSBindingConstants.CREATE_ALWAYS);
         return new JMSBindingServiceBindingProvider(component, service, binding.getSCABinding(), jmsBinding, workScheduler);
     }