Author: antelder
Date: Thu Sep 11 00:23:21 2008
New Revision: 694156
URL: http://svn.apache.org/viewvc?rev=694156&view=rev
Log:
Update for latest jms binding method signatures which were changed in
TUSCANY-2583
Modified:
tuscany/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
Modified:
tuscany/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
URL:
http://svn.apache.org/viewvc/tuscany/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java?rev=694156&r1=694155&r2=694156&view=diff
==============================================================================
---
tuscany/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
(original)
+++
tuscany/java/sca/modules/binding-sca-jms/src/main/java/org/apache/tuscany/sca/binding/sca/jms/JMSSCABindingProviderFactory.java
Thu Sep 11 00:23:21 2008
@@ -40,8 +40,10 @@
public class JMSSCABindingProviderFactory implements
BindingProviderFactory<DistributedSCABinding> {
private WorkScheduler workScheduler;
+ private ExtensionPointRegistry extensionPoints;
public JMSSCABindingProviderFactory(ExtensionPointRegistry
extensionPoints) {
+ this.extensionPoints = extensionPoints;
UtilityExtensionPoint utilities =
extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
workScheduler = utilities.getUtility(WorkScheduler.class);
assert workScheduler != null;
@@ -56,9 +58,9 @@
// 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);
+ // jmsBinding.setDestinationCreate(JMSBindingConstants.CREATE_NEVER);
- return new JMSBindingReferenceBindingProvider(component, reference,
jmsBinding);
+ return new JMSBindingReferenceBindingProvider(component, reference,
jmsBinding, extensionPoints);
}
public ServiceBindingProvider
createServiceBindingProvider(RuntimeComponent component,
@@ -66,7 +68,7 @@
DistributedSCABinding binding) {
JMSBinding jmsBinding = createBinding(binding);
jmsBinding.setDestinationCreate(JMSBindingConstants.CREATE_ALWAYS);
- return new JMSBindingServiceBindingProvider(component, service,
binding.getSCABinding(), jmsBinding, workScheduler);
+ return new JMSBindingServiceBindingProvider(component, service,
binding.getSCABinding(), jmsBinding, workScheduler, extensionPoints);
}
private JMSBinding createBinding(DistributedSCABinding binding) {
