Loading skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java +1 −1 Original line number Diff line number Diff line Loading @@ -11,7 +11,7 @@ import java.util.List; * * @author wusheng */ public enum RollingSelector implements WorkerSelector<Object> { public enum RollingSelector implements WorkerSelector { INSTANCE; /** Loading skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java +2 −1 Original line number Diff line number Diff line Loading @@ -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; Loading @@ -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); Loading Loading
skywalking-collector/skywalking-collector-cluster/src/main/java/com/a/eye/skywalking/collector/actor/selector/RollingSelector.java +1 −1 Original line number Diff line number Diff line Loading @@ -11,7 +11,7 @@ import java.util.List; * * @author wusheng */ public enum RollingSelector implements WorkerSelector<Object> { public enum RollingSelector implements WorkerSelector { INSTANCE; /** Loading
skywalking-collector/skywalking-collector-worker/src/main/java/com/a/eye/skywalking/collector/worker/applicationref/ApplicationRefMember.java +2 −1 Original line number Diff line number Diff line Loading @@ -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; Loading @@ -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); Loading