From 65ceb3f47a2e67b6f6909921fdc194440ed7f7e6 Mon Sep 17 00:00:00 2001
From: pengys5 <8082209@qq.com>
Date: Sat, 25 Feb 2017 19:52:50 +0800
Subject: [PATCH] no message

---
 .../a/eye/skywalking/collector/actor/AbstractWorker.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/skywalking-collector/skywalking-collector-actor/src/main/java/com/a/eye/skywalking/collector/actor/AbstractWorker.java b/skywalking-collector/skywalking-collector-actor/src/main/java/com/a/eye/skywalking/collector/actor/AbstractWorker.java
index e1a212119..c7e2b9054 100644
--- a/skywalking-collector/skywalking-collector-actor/src/main/java/com/a/eye/skywalking/collector/actor/AbstractWorker.java
+++ b/skywalking-collector/skywalking-collector-actor/src/main/java/com/a/eye/skywalking/collector/actor/AbstractWorker.java
@@ -38,12 +38,14 @@ public abstract class AbstractWorker extends UntypedActor {
         }
     }
 
-    public void tell(String workerRole, WorkerRouter router, Object message) throws Throwable {
+    protected void tell(String workerRole, WorkerRouter router, Object message) throws Throwable {
         router.find(workerRole).tell(message, getSelf());
     }
 
     void register(Member member) {
-        WorkerListenerMessage.RegisterMessage registerMessage = new WorkerListenerMessage.RegisterMessage(workerRole);
-        getContext().actorSelection(member.address() + "/user/" + WorkersListener.WorkName).tell(registerMessage, getSelf());
+        if (member.getRoles().equals(WorkersListener.WorkName)) {
+            WorkerListenerMessage.RegisterMessage registerMessage = new WorkerListenerMessage.RegisterMessage(workerRole);
+            getContext().actorSelection(member.address() + "/user/" + WorkersListener.WorkName).tell(registerMessage, getSelf());
+        }
     }
 }