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 log statement
This commit is contained in:
Timothy Bish 2014-02-22 16:45:40 -05:00
parent 914beaeb4c
commit 2b3c477752
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
View File

@ -20,7 +20,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
*
*
*/
class DedicatedTaskRunner implements TaskRunner {
@ -36,6 +36,7 @@ class DedicatedTaskRunner implements TaskRunner {
public DedicatedTaskRunner(final Task task, String name, int priority, boolean daemon) {
this.task = task;
thread = new Thread(name) {
@Override
public void run() {
try {
runTask();
@ -52,6 +53,7 @@ class DedicatedTaskRunner implements TaskRunner {
/**
*/
@Override
public void wakeup() throws InterruptedException {
synchronized (mutex) {
if (shutdown) {
@ -64,12 +66,13 @@ class DedicatedTaskRunner implements TaskRunner {
/**
* shut down the task
*
*
* @param timeout
* @throws InterruptedException
*/
@Override
public void shutdown(long timeout) throws InterruptedException {
LOG.trace("Shutdown timeout: {} task: {}", task);
LOG.trace("Shutdown timeout: {} task: {}", timeout, task);
synchronized (mutex) {
shutdown = true;
pending = true;
@ -85,9 +88,10 @@ class DedicatedTaskRunner implements TaskRunner {
/**
* shut down the task
*
*
* @throws InterruptedException
*/
@Override
public void shutdown() throws InterruptedException {
shutdown(0);
}