You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/02/13 13:33:14 UTC
[incubator-skywalking] branch datacarrier-consumer-pool updated:
Fix CI.
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch datacarrier-consumer-pool
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
The following commit(s) were added to refs/heads/datacarrier-consumer-pool by this push:
new e0c2273 Fix CI.
e0c2273 is described below
commit e0c22731af3c9f051c829d11bf7f1c6e19274fd0
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Wed Feb 13 21:33:04 2019 +0800
Fix CI.
---
.../skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java
index 6d80cc0..3dcc26b 100644
--- a/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java
+++ b/apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java
@@ -20,13 +20,12 @@ package org.apache.skywalking.apm.commons.datacarrier.consumer;
import java.util.ArrayList;
import java.util.concurrent.locks.ReentrantLock;
-import org.apache.skywalking.apm.commons.datacarrier.buffer.Buffer;
-import org.apache.skywalking.apm.commons.datacarrier.buffer.Channels;
+import org.apache.skywalking.apm.commons.datacarrier.buffer.*;
/**
* Pool of consumers <p> Created by wusheng on 2016/10/25.
*/
-public class ConsumeDriver<T> implements IDriver{
+public class ConsumeDriver<T> implements IDriver {
private boolean running;
private ConsumerThread[] consumerThreads;
private Channels<T> channels;