activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [09/19] git commit: https://issues.apache.org/jira/browse/AMQ-5071
Date Thu, 20 Mar 2014 20:15:39 GMT
https://issues.apache.org/jira/browse/AMQ-5071

fix log statement


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/12c9bde2
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/12c9bde2
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/12c9bde2

Branch: refs/heads/activemq-5.9
Commit: 12c9bde2776b63aff3f0ddd0b7b999ffeed085ec
Parents: fb4926d
Author: Timothy Bish <tabish121@gmai.com>
Authored: Sat Feb 22 16:45:40 2014 -0500
Committer: Hadrian Zbarcea <hadrian@apache.org>
Committed: Thu Mar 20 15:15:04 2014 -0400

----------------------------------------------------------------------
 .../org/apache/activemq/thread/DedicatedTaskRunner.java | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/12c9bde2/activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
----------------------------------------------------------------------
diff --git a/activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
b/activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
index 704cb22..f08d5ca 100644
--- a/activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
+++ b/activemq-client/src/main/java/org/apache/activemq/thread/DedicatedTaskRunner.java
@@ -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);
     }


Mime
View raw message