diff --git a/skywalking-collector/pom.xml b/skywalking-collector/pom.xml index 122b12c82..0b7ddef07 100644 --- a/skywalking-collector/pom.xml +++ b/skywalking-collector/pom.xml @@ -49,6 +49,7 @@ com.typesafe.akka akka-testkit_2.11 ${akka.version} + test com.a.eye diff --git a/skywalking-collector/skywalking-collector-worker/pom.xml b/skywalking-collector/skywalking-collector-worker/pom.xml index 0f03e8852..0615a0353 100644 --- a/skywalking-collector/skywalking-collector-worker/pom.xml +++ b/skywalking-collector/skywalking-collector-worker/pom.xml @@ -10,6 +10,7 @@ 4.0.0 skywalking-collector-worker + jar diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoerWorkerFactory.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoerWorkerFactory.java index 8a95becd9..df102eaa3 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoerWorkerFactory.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoerWorkerFactory.java @@ -9,11 +9,6 @@ public class ApplicationDiscoerWorkerFactory extends AbstractWorkerProvider { public static final String WorkerName = "ApplicationDiscoverMetric"; - @Override - public String workerName() { - return WorkerName; - } - @Override public Class workerClass() { return ApplicationDiscoverMetric.class; diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoverMetric.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoverMetric.java index 3ce558384..cb6187266 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoverMetric.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/metric/ApplicationDiscoverMetric.java @@ -9,7 +9,7 @@ import com.a.eye.skywalking.collector.actor.AbstractWorker; public class ApplicationDiscoverMetric extends AbstractWorker { @Override - public void onReceive(Object message) throws Throwable { + public void receive(Object message) throws Throwable { } }