From 2a6b52a262b7e0ecd902ea58cf3a65d3042dc7c4 Mon Sep 17 00:00:00 2001
From: Jonathan Cobb <jonathan@kyuss.org>
Date: Fri, 17 Jan 2020 10:38:00 -0500
Subject: [PATCH] print number of worker threads

---
 .../server/listener/NodeInitializerListener.java      | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/bubble-server/src/main/java/bubble/server/listener/NodeInitializerListener.java b/bubble-server/src/main/java/bubble/server/listener/NodeInitializerListener.java
index 5d3444df..09f2e423 100644
--- a/bubble-server/src/main/java/bubble/server/listener/NodeInitializerListener.java
+++ b/bubble-server/src/main/java/bubble/server/listener/NodeInitializerListener.java
@@ -38,11 +38,12 @@ public class NodeInitializerListener extends RestServerLifecycleListenerBase<Bub
         if (empty(allLocales)) die("beforeStart: no locales found");  // should never happen
 
         // if we are using the 'http' localNotificationStrategy, ensure we have enough worker threads
-        if (c.localNotificationStrategy() == LocalNotificationStrategy.http) {
-            if (!c.getHttp().hasWorkerThreads() || c.getHttp().getWorkerThreads() < MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY) {
-                log.info("beforeStart: http.workerThreads="+c.getHttp().getWorkerThreads()+" is not set or too low, increasing to "+MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY);
-                c.getHttp().setWorkerThreads(MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY);
-            }
+        if (c.localNotificationStrategy() == LocalNotificationStrategy.http
+                && !c.getHttp().hasWorkerThreads() || c.getHttp().getWorkerThreads() < MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY) {
+            log.info("beforeStart: http.workerThreads="+c.getHttp().getWorkerThreads()+" is not set or too low, increasing to "+MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY);
+            c.getHttp().setWorkerThreads(MIN_WORKER_THREADS_FOR_LOCAL_HTTP_NOTIFY);
+        } else {
+            log.info("beforeStart: http.workerThreads="+c.getHttp().getWorkerThreads());
         }
     }