You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by ch...@apache.org on 2011/05/06 21:28:21 UTC

svn commit: r1100344 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java

Author: charith
Date: Fri May  6 19:28:21 2011
New Revision: 1100344

URL: http://svn.apache.org/viewvc?rev=1100344&view=rev
Log:
Fixing a bug in Mediator Worker that can cause Dead Threads

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java?rev=1100344&r1=1100343&r2=1100344&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/MediatorWorker.java Fri May  6 19:28:21 2011
@@ -93,6 +93,12 @@ public class MediatorWorker implements R
                 warn(false, "Exception encountered but no fault handler found - " +
                     "message dropped", synCtx);
             }
+        } catch (Throwable e) {
+            String msg = "Unexpected error executing task/async inject, message dropped";
+            log.error(msg, e);
+            if (synCtx.getServiceLog() != null) {
+                synCtx.getServiceLog().error(msg, e);
+            }
         }
         synCtx = null;
         seq = null;