diff options
author | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2009-02-06 11:01:15 +0000 |
---|---|---|
committer | antelder <antelder@13f79535-47bb-0310-9956-ffa450edef68> | 2009-02-06 11:01:15 +0000 |
commit | b0a546d5031b286358f3971c90abe2de0203eaeb (patch) | |
tree | fe8ad85996d06d41555de834b6d7f92ea2e57ca6 /branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca | |
parent | cc432a93ea252848d93b40575ea48fbe7927cc03 (diff) |
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
Diffstat (limited to 'branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca')
-rw-r--r-- | branches/sca-java-1.x/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java | 7 |
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) { |