cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ff...@apache.org
Subject svn commit: r1141789 - in /cxf/branches/2.3.x-fixes: ./ rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java
Date Fri, 01 Jul 2011 04:16:27 GMT
Author: ffang
Date: Fri Jul  1 04:16:26 2011
New Revision: 1141789

URL: http://svn.apache.org/viewvc?rev=1141789&view=rev
Log:
Merged revisions 1141788 via svnmerge from 
https://svn.apache.org/repos/asf/cxf/branches/2.4.x-fixes

................
  r1141788 | ffang | 2011-07-01 11:45:23 +0800 (五, 01  7 2011) | 9 lines
  
  Merged revisions 1141787 via svnmerge from 
  https://svn.apache.org/repos/asf/cxf/trunk
  
  ........
    r1141787 | ffang | 2011-07-01 11:35:20 +0800 (五, 01  7 2011) | 1 line
    
    [CXF-3627]add a log in OneWayProcessorInterceptor to indicate the executor queue is full
and have to use the caller thread
  ........
................

Modified:
    cxf/branches/2.3.x-fixes/   (props changed)
    cxf/branches/2.3.x-fixes/rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java

Propchange: cxf/branches/2.3.x-fixes/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.

Modified: cxf/branches/2.3.x-fixes/rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java
URL: http://svn.apache.org/viewvc/cxf/branches/2.3.x-fixes/rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java?rev=1141789&r1=1141788&r2=1141789&view=diff
==============================================================================
--- cxf/branches/2.3.x-fixes/rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java
(original)
+++ cxf/branches/2.3.x-fixes/rt/core/src/main/java/org/apache/cxf/interceptor/OneWayProcessorInterceptor.java
Fri Jul  1 04:16:26 2011
@@ -22,8 +22,10 @@ package org.apache.cxf.interceptor;
 import java.io.IOException;
 import java.util.concurrent.Executor;
 import java.util.concurrent.RejectedExecutionException;
+import java.util.logging.Logger;
 
 import org.apache.cxf.Bus;
+import org.apache.cxf.common.logging.LogUtils;
 import org.apache.cxf.endpoint.Endpoint;
 import org.apache.cxf.io.DelegatingInputStream;
 import org.apache.cxf.message.Exchange;
@@ -41,6 +43,7 @@ import org.apache.cxf.workqueue.WorkQueu
 public class OneWayProcessorInterceptor extends AbstractPhaseInterceptor<Message> {
     public static final String USE_ORIGINAL_THREAD 
         = OneWayProcessorInterceptor.class.getName() + ".USE_ORIGINAL_THREAD"; 
+    private static final Logger LOG = LogUtils.getL7dLogger(OneWayProcessorInterceptor.class);
     
     public OneWayProcessorInterceptor() {
         super(Phase.PRE_LOGICAL);
@@ -116,6 +119,9 @@ public class OneWayProcessorInterceptor 
                     }
                 } catch (RejectedExecutionException e) {
                     //the executor queue is full, so run the task in the caller thread
+                    LOG.warning(
+                        "the executor queue is full, run the oneway invocation task in caller
thread." 
+                        + "Users can specify a larger executor queue to avoid this.");
                     chain.resume();
                 } catch (InterruptedException e) {
                     //ignore - likely a busy work queue so we'll just let the one-way go



Mime
View raw message