Fix: discovery service logs (apache#897)

willome · Nov 10, 2017 · 6278855 · 6278855
1 parent 29bd6c9
commit 6278855
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...discovery-service/src/main/java/org/apache/pulsar/discovery/service/DiscoveryService.java b/...discovery-service/src/main/java/org/apache/pulsar/discovery/service/DiscoveryService.java
@@ -104,13 +104,13 @@ public void startServer() throws Exception {
         bootstrap.childHandler(new ServiceChannelInitializer(this, config, false));
         // Bind and start to accept incoming connections.
         bootstrap.bind(config.getServicePort()).sync();
-        LOG.info("Started Pulsar Broker service on port {}", config.getWebServicePort());
+        LOG.info("Started Pulsar Discovery service on port {}", config.getWebServicePort());
 
         if (config.isTlsEnabled()) {
             ServerBootstrap tlsBootstrap = bootstrap.clone();
             tlsBootstrap.childHandler(new ServiceChannelInitializer(this, config, true));
             tlsBootstrap.bind(config.getServicePortTls()).sync();
-            LOG.info("Started Pulsar Broker TLS service on port {}", config.getWebServicePortTls());
+            LOG.info("Started Pulsar Discovery TLS service on port {}", config.getWebServicePortTls());
         }
     }
 

diff --git a/...ice/src/main/java/org/apache/pulsar/discovery/service/server/DiscoveryServiceStarter.java b/...ice/src/main/java/org/apache/pulsar/discovery/service/server/DiscoveryServiceStarter.java
@@ -53,7 +53,7 @@ public static void init(String configFile) throws Exception {
         checkArgument(!isEmpty(config.getZookeeperServers()), "zookeeperServers must be provided");
         checkArgument(!isEmpty(config.getGlobalZookeeperServers()), "global-zookeeperServers must be provided");
 
-        // create broker service
+        // create Discovery service
         DiscoveryService discoveryService = new DiscoveryService(config);
         // create a web-service
         final ServerManager server = new ServerManager(config);