setLoggingLevel

Author: scottf

build.gradle

@@ -8,7 +8,7 @@ plugins {
     id 'signing'
 }
 
-def jarVersion = "1.0.12"
+def jarVersion = "1.0.13"
 group = 'io.nats'
 
 def isMerge = System.getenv("BUILD_EVENT") == "push"

src/main/java/nats/io/NatsServerRunner.java

@@ -19,6 +19,7 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.logging.Level;
 import java.util.logging.Logger;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -27,7 +28,19 @@
 
 public class NatsServerRunner implements AutoCloseable {
 
-    private static final Logger LOGGER = Logger.getLogger(NatsServerRunner.class.getName());
+    private static Logger LOGGER;
+
+    static {
+        LOGGER = Logger.getLogger(NatsServerRunner.class.getName());
+    }
+
+    public static void setLogger(Logger logger) {
+        LOGGER = logger;
+    }
+
+    public static void setLoggingLevel(Level loggingLevel) {
+        LOGGER.setLevel(loggingLevel);
+    }
 
     private final int _port;
     private final File configFile;
@@ -255,7 +268,6 @@ public NatsServerRunner(String[] customArgs, int port, boolean debug) throws IOE
         this(port, debug, false, null, null, customArgs);
     }
 
-
     /**
      * Construct and start the Nats Server runner with options
      *

src/test/java/nats/io/NatsServerRunnerTest.java

@@ -19,6 +19,7 @@
 
 import java.io.IOException;
 import java.util.Arrays;
+import java.util.logging.Level;
 import java.util.stream.Stream;
 
 public class NatsServerRunnerTest extends TestBase {
@@ -87,4 +88,14 @@ public void testWithConfig(String configFile, boolean checkConnect) throws IOExc
             }
         }
     }
+
+    // THIS TEST IS RUN MANUALLY. THERE SHOULD BE NO SERVER OUTPUT
+    // COMMENT OUT the setLoggingLevel to see the output appear.
+    @Test
+    public void testLoggingLevel() throws IOException, InterruptedException {
+        NatsServerRunner.setLoggingLevel(Level.SEVERE);
+        try (NatsServerRunner runner = new NatsServerRunner()) {
+            connect(runner);
+        }
+    }
 }