Commit update to jms sca binding left off the change to the JMS binding to use the JMS Host

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

1 files changed, 6 insertions, 1 deletions

diff --git a/branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java b/branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
index d839602198..44ab8f3fbf 100644
--- a/branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
+++ b/branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
@@ -28,6 +28,8 @@ import org.apache.tuscany.sca.binding.jms.provider.JMSResourceFactoryExtensionPo
 import org.apache.tuscany.sca.binding.sca.DistributedSCABinding;
 import org.apache.tuscany.sca.core.ExtensionPointRegistry;
 import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.host.jms.JMSHostExtensionPoint;
+import org.apache.tuscany.sca.host.jms.JMSServiceListenerFactory;
 import org.apache.tuscany.sca.provider.BindingProviderFactory;
 import org.apache.tuscany.sca.provider.ReferenceBindingProvider;
 import org.apache.tuscany.sca.provider.ServiceBindingProvider;
@@ -44,6 +46,7 @@ public class JMSSCABindingProviderFactory implements BindingProviderFactory<Dist
     private WorkScheduler workScheduler;
     private ExtensionPointRegistry extensionPoints;
     private JMSResourceFactoryExtensionPoint jmsRFEP;
+    private JMSServiceListenerFactory serviceListenerFactory;
 
     public JMSSCABindingProviderFactory(ExtensionPointRegistry extensionPoints) {
         this.extensionPoints = extensionPoints;
@@ -54,6 +57,8 @@ public class JMSSCABindingProviderFactory implements BindingProviderFactory<Dist
         if (jmsRFEP == null) {
             jmsRFEP = new AMQResourceFactoryExtensionPoint();
         }
+        JMSHostExtensionPoint jmsHostExtensionPoint = (JMSHostExtensionPoint)extensionPoints.getExtensionPoint(JMSHostExtensionPoint.class);
+        serviceListenerFactory = jmsHostExtensionPoint.getJMSServiceListenerFactory();
     }    
 
     public ReferenceBindingProvider createReferenceBindingProvider(RuntimeComponent component,
@@ -77,7 +82,7 @@ public class JMSSCABindingProviderFactory implements BindingProviderFactory<Dist
         JMSBinding jmsBinding = createBinding(binding);
         jmsBinding.setDestinationCreate(JMSBindingConstants.CREATE_ALWAYS);
         JMSResourceFactory jmsRF = jmsRFEP.createJMSResourceFactory(jmsBinding);
-        return new JMSBindingServiceBindingProvider(component, service, binding.getSCABinding(), jmsBinding, workScheduler, extensionPoints, jmsRF);
+        return new JMSBindingServiceBindingProvider(component, service, binding.getSCABinding(), jmsBinding, serviceListenerFactory, extensionPoints, jmsRF);
     }
 
     private JMSBinding createBinding(DistributedSCABinding binding) {