Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5071 

fix bad logger
This commit is contained in:
Timothy Bish 2014-02-21 12:15:13 -05:00
parent 232b8c51e9
commit 914beaeb4c
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-client/src/main/java/org/apache/activemq/thread/PooledTaskRunner.java
View File

@ -22,7 +22,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
*
*
*/
class PooledTaskRunner implements TaskRunner {
@ -41,6 +41,7 @@ class PooledTaskRunner implements TaskRunner {
this.maxIterationsPerRun = maxIterationsPerRun;
this.task = task;
runable = new Runnable() {
@Override
public void run() {
runningThread = Thread.currentThread();
try {
@ -56,6 +57,7 @@ class PooledTaskRunner implements TaskRunner {
/**
* We Expect MANY wakeup calls on the same TaskRunner.
*/
@Override
public void wakeup() throws InterruptedException {
synchronized (runable) {
@ -88,8 +90,9 @@ class PooledTaskRunner implements TaskRunner {
*
* @throws InterruptedException
*/
@Override
public void shutdown(long timeout) throws InterruptedException {
LOG.trace("Shutdown timeout: {} task: {}", task);
LOG.trace("Shutdown timeout: {} task: {}", timeout, task);
synchronized (runable) {
shutdown = true;
// the check on the thread is done
@ -104,6 +107,7 @@ class PooledTaskRunner implements TaskRunner {
}
}
@Override
public void shutdown() throws InterruptedException {
shutdown(0);
}
@ -132,7 +136,7 @@ class PooledTaskRunner implements TaskRunner {
}
}
} finally {
synchronized( runable ) {
synchronized (runable) {
iterating = false;
runable.notifyAll();
if (shutdown) {