diff --git a/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java b/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java index 8ef322c6b..0de97621f 100644 --- a/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java +++ b/skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java @@ -11,7 +11,7 @@ import java.util.List; * * @author wusheng */ -public enum RollingSelector implements WorkerSelector { +public enum RollingSelector implements WorkerSelector { INSTANCE; /** diff --git a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java index 28d746aea..ec33bceae 100644 --- a/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java +++ b/skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java @@ -2,6 +2,7 @@ package com.a.eye.skywalking.collector.worker.applicationref; import akka.actor.ActorRef; import com.a.eye.skywalking.collector.actor.AbstractMember; +import com.a.eye.skywalking.collector.actor.AbstractSyncMember; import com.a.eye.skywalking.collector.actor.AbstractSyncMemberProvider; import com.a.eye.skywalking.collector.actor.selector.RollingSelector; import com.a.eye.skywalking.collector.worker.applicationref.presistence.DAGNodeRefPersistence; @@ -10,7 +11,7 @@ import com.a.eye.skywalking.trace.TraceSegment; /** * @author pengys5 */ -public class ApplicationRefMember extends AbstractMember { +public class ApplicationRefMember extends AbstractSyncMember { public ApplicationRefMember(ActorRef actorRef) throws Throwable { super(actorRef);