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 2020/04/05 23:17:44 UTC
[skywalking] branch master updated: Update ConsumeDriver.java
(#4610)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git
The following commit(s) were added to refs/heads/master by this push:
new 778b86e Update ConsumeDriver.java (#4610)
778b86e is described below
commit 778b86e1de0c83810574356e6393db785c85d96a
Author: Brandon Fergerson <fe...@gmail.com>
AuthorDate: Sun Apr 5 19:17:31 2020 -0400
Update ConsumeDriver.java (#4610)
spelling fix
---
.../skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 fcf06ed..4f01f32 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
@@ -34,7 +34,7 @@ public class ConsumeDriver<T> implements IDriver {
long consumeCycle) {
this(channels, num);
for (int i = 0; i < num; i++) {
- consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumser." + i + ".Thread", getNewConsumerInstance(consumerClass), consumeCycle);
+ consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumer." + i + ".Thread", getNewConsumerInstance(consumerClass), consumeCycle);
consumerThreads[i].setDaemon(true);
}
}
@@ -43,7 +43,7 @@ public class ConsumeDriver<T> implements IDriver {
this(channels, num);
prototype.init();
for (int i = 0; i < num; i++) {
- consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumser." + i + ".Thread", prototype, consumeCycle);
+ consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumer." + i + ".Thread", prototype, consumeCycle);
consumerThreads[i].setDaemon(true);
}