You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by gg...@apache.org on 2015/12/08 18:30:54 UTC
[7/7] logging-log4j2 git commit: Use TimeUnit instead of magic number.
Use TimeUnit instead of magic number.
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/f882b66f
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/f882b66f
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/f882b66f
Branch: refs/heads/master
Commit: f882b66ff39920a198a7d8dfa82fb1eef7fd5ec6
Parents: 84b6088
Author: ggregory <gg...@apache.org>
Authored: Mon Dec 7 20:19:32 2015 -0500
Committer: ggregory <gg...@apache.org>
Committed: Mon Dec 7 20:19:32 2015 -0500
----------------------------------------------------------------------
.../org/apache/logging/log4j/flume/appender/FlumeAvroManager.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/f882b66f/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
----------------------------------------------------------------------
diff --git a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
index ef3234a..dd5dd96 100644
--- a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
+++ b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
@@ -17,6 +17,7 @@
package org.apache.logging.log4j.flume.appender;
import java.util.Properties;
+import java.util.concurrent.TimeUnit;
import org.apache.flume.Event;
import org.apache.flume.api.RpcClient;
@@ -70,7 +71,7 @@ public class FlumeAvroManager extends AbstractFlumeManager {
this.agents = agents;
this.batchSize = batchSize;
this.delayMillis = delayMillis;
- this.delayNanos = delayMillis * 1000000;
+ this.delayNanos = TimeUnit.MILLISECONDS.toNanos(delayMillis);
this.retries = retries;
this.connectTimeoutMillis = connectTimeout;
this.requestTimeoutMillis = requestTimeout;