Add support for using Tuscany threads instead on setMessageListener in a JEE container environment

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

2 files changed, 12 insertions, 3 deletions

diff --git a/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceBindingProvider.java b/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceBindingProvider.java
index 58a50d46dc..0450d07071 100644
--- a/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceBindingProvider.java
+++ b/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceBindingProvider.java
@@ -31,6 +31,7 @@ import org.apache.tuscany.sca.binding.ws.axis2.Axis2ServiceProvider;
 import org.apache.tuscany.sca.binding.ws.wsdlgen.BindingWSDLGenerator;
 import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
 import org.apache.tuscany.sca.core.ExtensionPointRegistry;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
 import org.apache.tuscany.sca.databinding.DataBindingExtensionPoint;
 import org.apache.tuscany.sca.host.http.ServletHost;
 import org.apache.tuscany.sca.host.http.ServletHostExtensionPoint;
@@ -40,6 +41,7 @@ import org.apache.tuscany.sca.policy.util.PolicyHandlerTuple;
 import org.apache.tuscany.sca.provider.ServiceBindingProvider;
 import org.apache.tuscany.sca.runtime.RuntimeComponent;
 import org.apache.tuscany.sca.runtime.RuntimeComponentService;
+import org.apache.tuscany.sca.work.WorkScheduler;
 
 /**
  * The service binding provider for the remote sca binding implementation. Relies on the 
@@ -69,6 +71,8 @@ public class Axis2SCAServiceBindingProvider implements ServiceBindingProvider {
         ModelFactoryExtensionPoint modelFactories = extensionPoints.getExtensionPoint(ModelFactoryExtensionPoint.class);
         MessageFactory messageFactory = modelFactories.getFactory(MessageFactory.class); 
         DataBindingExtensionPoint dataBindings = extensionPoints.getExtensionPoint(DataBindingExtensionPoint.class);
+        UtilityExtensionPoint utilities = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
+        WorkScheduler workScheduler = utilities.getUtility(WorkScheduler.class);
 
         this.binding = binding.getSCABinding();
         wsBinding = modelFactories.getFactory(WebServiceBindingFactory.class).createWebServiceBinding();
@@ -88,7 +92,8 @@ public class Axis2SCAServiceBindingProvider implements ServiceBindingProvider {
                                                    wsBinding,
                                                    servletHost,
                                                    messageFactory,
-                                                   policyHandlerClassnames);
+                                                   policyHandlerClassnames,
+                                                   workScheduler);
     }
 
     public InterfaceContract getBindingInterfaceContract() {
diff --git a/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceProvider.java b/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceProvider.java
index cf13d821f7..dd66415cca 100644
--- a/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceProvider.java
+++ b/branches/sca-java-1.x/modules/binding-sca-axis2/src/main/java/org/apache/tuscany/sca/binding/sca/axis2/impl/Axis2SCAServiceProvider.java
@@ -25,11 +25,13 @@ import org.apache.tuscany.sca.assembly.Binding;
 import org.apache.tuscany.sca.assembly.SCABinding;

 import org.apache.tuscany.sca.binding.ws.WebServiceBinding;

 import org.apache.tuscany.sca.binding.ws.axis2.Axis2ServiceProvider;

+import org.apache.tuscany.sca.core.UtilityExtensionPoint;

 import org.apache.tuscany.sca.host.http.ServletHost;

 import org.apache.tuscany.sca.invocation.MessageFactory;

 import org.apache.tuscany.sca.policy.util.PolicyHandlerTuple;

 import org.apache.tuscany.sca.runtime.RuntimeComponent;

 import org.apache.tuscany.sca.runtime.RuntimeComponentService;

+import org.apache.tuscany.sca.work.WorkScheduler;

 

 /**

  * A specialization of the Axis2BindingProvider that just switches in the SCABinding model

@@ -58,14 +60,16 @@ public class Axis2SCAServiceProvider extends Axis2ServiceProvider {
                                    WebServiceBinding wsBinding,

                                    ServletHost servletHost,

                                    MessageFactory messageFactory,

-                                   List<PolicyHandlerTuple> policyHandlerClassnames)  {

+                                   List<PolicyHandlerTuple> policyHandlerClassnames,

+                                   WorkScheduler workScheduler)  {

         

         super(component, 

                 service, 

                 wsBinding, 

                 servletHost,

                 messageFactory,

-                policyHandlerClassnames);

+                policyHandlerClassnames,

+                workScheduler);

 

         this.binding = binding;

     }