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;