Author: ffang
Date: Fri Nov 30 09:48:13 2012
New Revision: 1415561
URL: http://svn.apache.org/viewvc?rev=1415561&view=rev
Log:
[SMXCOMP-956]use one thread directly rather than the threadpool as this method
actually get invoked only once
Modified:
servicemix/components/trunk/shared-libraries/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
Modified:
servicemix/components/trunk/shared-libraries/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
URL:
http://svn.apache.org/viewvc/servicemix/components/trunk/shared-libraries/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java?rev=1415561&r1=1415560&r2=1415561&view=diff
==============================================================================
---
servicemix/components/trunk/shared-libraries/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
(original)
+++
servicemix/components/trunk/shared-libraries/servicemix-common/src/main/java/org/apache/servicemix/common/AsyncBaseLifeCycle.java
Fri Nov 30 09:48:13 2012
@@ -320,12 +320,12 @@ public class AsyncBaseLifeCycle implemen
if (doPoll) {
synchronized (this.polling) {
- consumerExecutor.execute(new Runnable() {
+ new Thread() {
public void run() {
poller = Thread.currentThread();
pollDeliveryChannel();
}
- });
+ }.start();
polling.wait();
}
}
@@ -385,13 +385,15 @@ public class AsyncBaseLifeCycle implemen
}
}
if (oldStatus == ExchangeStatus.ACTIVE) {
- newExchange.setStatus(ExchangeStatus.ERROR);
- if (t instanceof RejectedExecutionException) {
- if (t.getMessage() == null ||
t.getMessage().length() == 0) {
- t = new RuntimeException("Task rejected
from java.util.concurrent.ThreadPoolExecutor, need bigger ThreadPool", t);
- }
+ newExchange.setStatus(ExchangeStatus.ERROR);
+ if (t instanceof RejectedExecutionException) {
+ if (t.getMessage() == null ||
t.getMessage().length() == 0) {
+ t = new RuntimeException(
+ "Task rejected from
java.util.concurrent.ThreadPoolExecutor, need bigger ThreadPool",
+ t);
}
- newExchange.setError(t instanceof Exception ?
(Exception) t : new Exception(t));
+ }
+ newExchange.setError(t instanceof Exception ?
(Exception)t : new Exception(t));
channel.send(newExchange);
}
} catch (Exception inner) {
