SWITCHYARD-436 temporary fix for threading issue in AS7 WS stack

jboss-switchyard · Nov 10, 2011 · c266614 · c266614
1 parent e3b17a9
commit c266614
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/soap/src/main/java/org/switchyard/component/soap/InboundHandler.java b/soap/src/main/java/org/switchyard/component/soap/InboundHandler.java
@@ -92,6 +92,8 @@ public InboundHandler(final SOAPBindingModel config) {
      * @throws WebServicePublishException If unable to publish the endpoint
      */
     public void start(ServiceReference service) throws WebServicePublishException {
+        //XXX: REMOVE THIS SYNCHRONIZED: once threading issues in AS7 WS are fixed
+        synchronized (BaseWebService.class) {
         try {
             _service = service;
             PortName portName = _config.getPort();
@@ -130,13 +132,17 @@ public void start(ServiceReference service) throws WebServicePublishException {
         } catch (WSDLException e) {
             throw new WebServicePublishException(e);
         }
+        }
     }
 
     /**
      * Stop lifecycle.
      */
     public void stop() {
+        //XXX: REMOVE THIS SYNCHRONIZED: once threading issues in AS7 WS are fixed
+        synchronized (BaseWebService.class) {
         _endpoint.stop();
+        }
         LOGGER.info("WebService " + _config.getPort() + " stopped.");
     }
 

diff --git a/soap/src/main/java/org/switchyard/component/soap/OutboundHandler.java b/soap/src/main/java/org/switchyard/component/soap/OutboundHandler.java
@@ -71,6 +71,8 @@ public OutboundHandler(final SOAPBindingModel config) {
      * @throws WebServiceConsumeException If unable to load the WSDL
      */
     public void start() throws WebServiceConsumeException {
+        //XXX: REMOVE THIS SYNCHRONIZED: once threading issues in AS7 WS are fixed
+        synchronized (BaseWebService.class) {
         if (_dispatcher == null) {
             try {
                 PortName portName = _config.getPort();
@@ -94,6 +96,7 @@ public void start() throws WebServiceConsumeException {
                 throw new WebServiceConsumeException(wsdle);
             }
         }
+        }
     }
 
     /**