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
