[incubator-pulsar] branch master updated: Start function worker service after broker is fully started (#1589)

[mmerli]

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

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 44ace52  Start function worker service after broker is fully started 
(#1589)
44ace52 is described below

commit 44ace5262000b0892c019810908c5412a3a3a50a
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Mon Apr 16 14:41:12 2018 -0700

    Start function worker service after broker is fully started (#1589)
---
 .../src/main/java/org/apache/pulsar/broker/PulsarService.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index 0370346..3d14b8b 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -410,9 +410,6 @@ public class PulsarService implements AutoCloseable {
 
             leaderElectionService.start();
 
-            // start function worker service if necessary
-            this.startWorkerService();
-
             LOG.info("Starting Pulsar Broker service; version: '{}'", ( 
brokerVersion != null ? brokerVersion : "unknown" )  );
 
             webService.start();
@@ -424,6 +421,9 @@ public class PulsarService implements AutoCloseable {
             state = State.Started;
 
             acquireSLANamespace();
+            
+            // start function worker service if necessary
+            this.startWorkerService();
 
             LOG.info("messaging service is ready, bootstrap service on 
port={}, broker url={}, cluster={}, configs={}",
                     config.getWebServicePort(), brokerServiceUrl, 
config.getClusterName(),

-- 
To stop receiving notification emails like this one, please contact
mme...@apache.org.