From dc0f2185ab02615e2bf93c619bd8e35eab870686 Mon Sep 17 00:00:00 2001
From: zhouyuyan <joy.zhou@honeywell.com>
Date: Fri, 19 Jan 2018 13:53:47 +0800
Subject: [PATCH] skip self

---
 broker/broker.go | 4 ++++
 broker/client.go | 5 +----
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/broker/broker.go b/broker/broker.go
index 7c4a1a1..74990b6 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -450,6 +450,10 @@ func (b *Broker) connectRouter(id, addr string) {
 }
 
 func (b *Broker) checkNodeExist(id, url string) bool {
+	if id == b.id {
+		return false
+	}
+
 	for k, v := range b.nodes {
 		if k == id {
 			return true
diff --git a/broker/client.go b/broker/client.go
index 852507b..35c98ec 100644
--- a/broker/client.go
+++ b/broker/client.go
@@ -522,10 +522,7 @@ func (c *client) Close() {
 
 		//do reconnect
 		if c.typ == REMOTE {
-			localUrl := c.info.localIP + ":" + c.broker.config.Cluster.Port
-			if c.route.remoteUrl != localUrl {
-				go b.connectRouter(c.route.remoteID, c.route.remoteUrl)
-			}
+			go b.connectRouter(c.route.remoteID, c.route.remoteUrl)
 		}
 	}
 }