[jboss-cvs] jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor ...

[Takuro Okada]

  User: tokada  
  Date: 06/12/12 00:40:57

  Modified:    java/src/expansion/org/jboss/profiler/exp/agent/interceptor   
                        Tag: JBossProfiler_Expansion AopInterceptor.java
                        ServletInterceptor.java DriverWrapper.java
  Log:
  Added error messages.
  
  Revision  Changes    Path
  No                   revision
  
  
  No                   revision
  
  
  1.1.2.6   +6 -1      jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/AopInterceptor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: AopInterceptor.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/AopInterceptor.java,v
  retrieving revision 1.1.2.5
  retrieving revision 1.1.2.6
  diff -u -b -r1.1.2.5 -r1.1.2.6
  --- AopInterceptor.java	28 Nov 2006 05:40:11 -0000	1.1.2.5
  +++ AopInterceptor.java	12 Dec 2006 05:40:57 -0000	1.1.2.6
  @@ -26,6 +26,7 @@
   import java.lang.reflect.Method;
   import java.util.Arrays;
   import java.util.concurrent.LinkedBlockingQueue;
  +import java.util.concurrent.RejectedExecutionException;
   import java.util.concurrent.ThreadPoolExecutor;
   import java.util.concurrent.TimeUnit;
   import java.util.concurrent.atomic.AtomicBoolean;
  @@ -184,7 +185,11 @@
           factory.updateCollector(collector);
           long threadId = RequestSequence.get();
           if(async) {
  +            try {
               asyncExecutor.execute(new InvocationSubmissionWrapper(collector, invocation, threadId));
  +            } catch (RejectedExecutionException e) {
  +                logger.error("A collector was rejected to insert into the collector pool.");
  +            }
           } else {
               processCollection(collector, invocation, threadId);
           }
  
  
  
  1.1.2.6   +6 -1      jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/ServletInterceptor.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ServletInterceptor.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/ServletInterceptor.java,v
  retrieving revision 1.1.2.5
  retrieving revision 1.1.2.6
  diff -u -b -r1.1.2.5 -r1.1.2.6
  --- ServletInterceptor.java	28 Nov 2006 02:49:12 -0000	1.1.2.5
  +++ ServletInterceptor.java	12 Dec 2006 05:40:57 -0000	1.1.2.6
  @@ -26,6 +26,7 @@
   import java.lang.reflect.Constructor;
   import java.util.Map;
   import java.util.concurrent.LinkedBlockingQueue;
  +import java.util.concurrent.RejectedExecutionException;
   import java.util.concurrent.ThreadPoolExecutor;
   import java.util.concurrent.TimeUnit;
   import java.util.concurrent.atomic.AtomicBoolean;
  @@ -152,7 +153,11 @@
   	    if(operationName!=null) {
               factory.updateCollector(collector);
               if(async) {
  +                try {
                   asyncExecutor.execute(new InvocationSubmissionWrapper(collector, retrieveParameter(servletRequest), threadId));
  +                } catch (RejectedExecutionException e) {
  +                    logger.error("A collector was rejected to insert into the collector pool.");
  +                }
               } else {
                   processCollection(collector, retrieveParameter(servletRequest), threadId);
               }
  
  
  
  1.1.2.8   +6 -1      jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/DriverWrapper.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: DriverWrapper.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-profiler/java/src/expansion/org/jboss/profiler/exp/agent/interceptor/Attic/DriverWrapper.java,v
  retrieving revision 1.1.2.7
  retrieving revision 1.1.2.8
  diff -u -b -r1.1.2.7 -r1.1.2.8
  --- DriverWrapper.java	28 Nov 2006 05:40:11 -0000	1.1.2.7
  +++ DriverWrapper.java	12 Dec 2006 05:40:57 -0000	1.1.2.8
  @@ -31,6 +31,7 @@
   import java.util.Arrays;
   import java.util.Properties;
   import java.util.concurrent.LinkedBlockingQueue;
  +import java.util.concurrent.RejectedExecutionException;
   import java.util.concurrent.ThreadPoolExecutor;
   import java.util.concurrent.TimeUnit;
   import java.util.concurrent.atomic.AtomicBoolean;
  @@ -188,7 +189,11 @@
           factory.updateCollector(collector);
           long threadId = RequestSequence.get();
           if(async) {
  +            try {
               asyncExecutor.execute(new InvocationSubmissionWrapper(collector, threadId, method, args));
  +            } catch (RejectedExecutionException e) {
  +                logger.error("A collector was rejected to insert into the collector pool.");
  +            }
           } else {
               processCollection(collector, threadId, method, args);
           }