[incubator-skywalking] branch reconnect updated: Remove notify in new channel created.

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch reconnect
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git


The following commit(s) were added to refs/heads/reconnect by this push:
     new 656b651  Remove notify in new channel created.
656b651 is described below

commit 656b65128f4c1e847331f3967547320d1741fe1e
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Wed Jan 23 22:30:51 2019 +0800

    Remove notify in new channel created.
---
 .../apache/skywalking/apm/agent/core/remote/GRPCChannelManager.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/GRPCChannelManager.java b/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/GRPCChannelManager.java
index 81895b3..b5ddd84 100644
--- a/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/GRPCChannelManager.java
+++ b/apm-sniffer/apm-agent-core/src/main/java/org/apache/skywalking/apm/agent/core/remote/GRPCChannelManager.java
@@ -94,7 +94,7 @@ public class GRPCChannelManager implements BootService, Runnable {
                         server = grpcServers.get(index);
                         String[] ipAndPort = server.split(":");
 
-                        if(managedChannel != null){
+                        if (managedChannel != null) {
                             managedChannel.shutdownNow();
                         }
 
@@ -111,7 +111,6 @@ public class GRPCChannelManager implements BootService, Runnable {
                     return;
                 } catch (Throwable t) {
                     logger.error(t, "Create channel to {} fail.", server);
-                    notify(GRPCChannelStatus.DISCONNECT);
                 }
             }