Vertx 42, cleaning up the TCCL stuff

bom/application/pom.xml

@@ -109,7 +109,7 @@
         <wildfly-elytron.version>1.16.1.Final</wildfly-elytron.version>
         <jboss-modules.version>1.8.7.Final</jboss-modules.version>
         <jboss-threads.version>3.4.0.Final</jboss-threads.version>
-        <vertx.version>4.1.2</vertx.version>
+        <vertx.version>4.2.0-SNAPSHOT</vertx.version>
         <httpclient.version>4.5.13</httpclient.version>
         <httpcore.version>4.4.14</httpcore.version>
         <httpasync.version>4.1.4</httpasync.version>

core/deployment/src/main/java/io/quarkus/deployment/console/ConsoleStateManager.java

@@ -85,8 +85,10 @@ public static void init(QuarkusConsole console, DevModeType devModeType) {
             return;
         }
         initialized = true;
-        console.setInputHandler(INSTANCE.consumer);
-        INSTANCE.installBuiltins(devModeType);
+        if (console.isInputSupported()) {
+            console.setInputHandler(INSTANCE.consumer);
+            INSTANCE.installBuiltins(devModeType);
+        }
     }
 
     void installBuiltins(DevModeType devModeType) {

core/deployment/src/main/java/io/quarkus/deployment/dev/testing/JunitTestRunner.java

@@ -133,6 +133,12 @@ public void runTests() {
         long start = System.currentTimeMillis();
         ClassLoader old = Thread.currentThread().getContextClassLoader();
         try (QuarkusClassLoader tcl = testApplication.createDeploymentClassLoader()) {
+            synchronized (this) {
+                if (aborted) {
+                    return;
+                }
+                testsRunning = true;
+            }
             Thread.currentThread().setContextClassLoader(tcl);
             Consumer currentTestAppConsumer = (Consumer) tcl.loadClass(CurrentTestApplication.class.getName()).newInstance();
             currentTestAppConsumer.accept(testApplication);
@@ -408,9 +414,18 @@ public void reportingEntryPublished(TestIdentifier testIdentifier, ReportEntry e
         } catch (Exception e) {
             throw new RuntimeException(e);
         } finally {
-            TracingHandler.setTracingHandler(null);
-            QuarkusConsole.INSTANCE.setOutputFilter(null);
-            Thread.currentThread().setContextClassLoader(old);
+            try {
+                TracingHandler.setTracingHandler(null);
+                QuarkusConsole.INSTANCE.setOutputFilter(null);
+                Thread.currentThread().setContextClassLoader(old);
+            } finally {
+                synchronized (this) {
+                    testsRunning = false;
+                    if (aborted) {
+                        notifyAll();
+                    }
+                }
+            }
         }
     }
 
@@ -424,6 +439,13 @@ public synchronized void abort() {
         }
         aborted = true;
         notifyAll();
+        while (testsRunning) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                //ignore
+            }
+        }
     }
 
     public synchronized void pause() {

core/deployment/src/main/java/io/quarkus/deployment/dev/testing/TestSupport.java

@@ -142,7 +142,11 @@ public void init() {
                 cl.addCloseTask(new Runnable() {
                     @Override
                     public void run() {
-                        testCuratedApplication.close();
+                        try {
+                            stop();
+                        } finally {
+                            testCuratedApplication.close();
+                        }
                     }
                 });
 

core/deployment/src/main/java/io/quarkus/deployment/dev/testing/TestTracingProcessor.java

@@ -77,14 +77,6 @@ void startTesting(TestConfig config, LiveReloadBuildItem liveReloadBuildItem,
                 testSupport.stop();
             }
         }
-
-        QuarkusClassLoader cl = (QuarkusClassLoader) Thread.currentThread().getContextClassLoader();
-        ((QuarkusClassLoader) cl.parent()).addCloseTask(new Runnable() {
-            @Override
-            public void run() {
-                testSupport.stop();
-            }
-        });
     }
 
     @BuildStep(onlyIf = IsTest.class)

core/deployment/src/main/java/io/quarkus/deployment/logging/LoggingResourceProcessor.java

@@ -236,6 +236,12 @@ public void accept(LogRecord logRecord, Consumer<LogRecord> logRecordConsumer) {
                 }
             }
         };
+        ((QuarkusClassLoader) getClass().getClassLoader()).addCloseTask(new Runnable() {
+            @Override
+            public void run() {
+                CurrentAppExceptionHighlighter.THROWABLE_FORMATTER = null;
+            }
+        });
     }
 
     @BuildStep

core/devmode-spi/src/main/java/io/quarkus/dev/console/BasicConsole.java

@@ -156,4 +156,9 @@ public void write(byte[] buf, int off, int len) {
         write(new String(buf, off, len, StandardCharsets.UTF_8));
     }
 
+    @Override
+    public boolean isInputSupported() {
+        return inputSupport;
+    }
+
 }

core/devmode-spi/src/main/java/io/quarkus/dev/console/QuarkusConsole.java

@@ -100,4 +100,7 @@ public void setOutputFilter(Predicate<String> logHandler) {
         this.outputFilter = logHandler;
     }
 
+    public boolean isInputSupported() {
+        return true;
+    }
 }

core/devmode-spi/src/main/java/io/quarkus/dev/testing/ContinuousTestingWebsocketListener.java

@@ -14,7 +14,7 @@ public static Consumer<State> getStateListener() {
 
     public static void setStateListener(Consumer<State> stateListener) {
         ContinuousTestingWebsocketListener.stateListener = stateListener;
-        if (lastState != null) {
+        if (lastState != null && stateListener != null) {
             stateListener.accept(lastState);
         }
     }

core/runtime/src/main/java/io/quarkus/runtime/logging/LoggingSetupRecorder.java

@@ -20,6 +20,7 @@
 import java.util.logging.Formatter;
 import java.util.logging.Handler;
 import java.util.logging.Level;
+import java.util.logging.LogManager;
 import java.util.logging.LogRecord;
 
 import org.graalvm.nativeimage.ImageInfo;
@@ -102,30 +103,34 @@ public void accept(String loggerName, CleanupFilterConfig config) {
                 }
             });
         }
+        LogCleanupFilter cleanupFiler = new LogCleanupFilter(filterElements);
+        for (Handler handler : LogManager.getLogManager().getLogger("").getHandlers()) {
+            handler.setFilter(cleanupFiler);
+        }
 
         final ArrayList<Handler> handlers = new ArrayList<>(3 + additionalHandlers.size());
 
         if (config.console.enable) {
-            final Handler consoleHandler = configureConsoleHandler(config.console, consoleConfig, errorManager, filterElements,
+            final Handler consoleHandler = configureConsoleHandler(config.console, consoleConfig, errorManager, cleanupFiler,
                     possibleFormatters, possibleBannerSupplier, launchMode);
             errorManager = consoleHandler.getErrorManager();
             handlers.add(consoleHandler);
         }
 
         if (config.file.enable) {
-            handlers.add(configureFileHandler(config.file, errorManager, filterElements));
+            handlers.add(configureFileHandler(config.file, errorManager, cleanupFiler));
         }
 
         if (config.syslog.enable) {
-            final Handler syslogHandler = configureSyslogHandler(config.syslog, errorManager, filterElements);
+            final Handler syslogHandler = configureSyslogHandler(config.syslog, errorManager, cleanupFiler);
             if (syslogHandler != null) {
                 handlers.add(syslogHandler);
             }
         }
 
         if (!categories.isEmpty()) {
             Map<String, Handler> namedHandlers = createNamedHandlers(config, consoleConfig, possibleFormatters, errorManager,
-                    filterElements, launchMode);
+                    cleanupFiler, launchMode);
 
             Map<String, Handler> additionalNamedHandlersMap;
             if (additionalNamedHandlers.isEmpty()) {
@@ -166,7 +171,7 @@ public void accept(String categoryName, CategoryConfig config) {
             if (optional.isPresent()) {
                 final Handler handler = optional.get();
                 handler.setErrorManager(errorManager);
-                handler.setFilter(new LogCleanupFilter(filterElements));
+                handler.setFilter(cleanupFiler);
                 handlers.add(handler);
             }
         }
@@ -191,18 +196,20 @@ public static void initializeBuildTimeLogging(LogConfig config, LogBuildTimeConf
             filterElements.add(
                     new LogCleanupFilterElement(entry.getKey(), entry.getValue().targetLevel, entry.getValue().ifStartsWith));
         }
+        LogCleanupFilter logCleanupFilter = new LogCleanupFilter(filterElements);
 
         final ArrayList<Handler> handlers = new ArrayList<>(3);
 
         if (config.console.enable) {
-            final Handler consoleHandler = configureConsoleHandler(config.console, consoleConfig, errorManager, filterElements,
+            final Handler consoleHandler = configureConsoleHandler(config.console, consoleConfig, errorManager,
+                    logCleanupFilter,
                     Collections.emptyList(), new RuntimeValue<>(Optional.empty()), launchMode);
             errorManager = consoleHandler.getErrorManager();
             handlers.add(consoleHandler);
         }
 
         Map<String, Handler> namedHandlers = createNamedHandlers(config, consoleConfig, Collections.emptyList(), errorManager,
-                filterElements, launchMode);
+                logCleanupFilter, launchMode);
 
         for (Map.Entry<String, CategoryConfig> entry : categories.entrySet()) {
             final CategoryBuildTimeConfig buildCategory = isSubsetOf(entry.getKey(), buildConfig.categories);
@@ -262,15 +269,15 @@ private static CategoryBuildTimeConfig isSubsetOf(String categoryName, Map<Strin
 
     private static Map<String, Handler> createNamedHandlers(LogConfig config, ConsoleRuntimeConfig consoleRuntimeConfig,
             List<RuntimeValue<Optional<Formatter>>> possibleFormatters, ErrorManager errorManager,
-            List<LogCleanupFilterElement> filterElements, LaunchMode launchMode) {
+            LogCleanupFilter cleanupFilter, LaunchMode launchMode) {
         Map<String, Handler> namedHandlers = new HashMap<>();
         for (Entry<String, ConsoleConfig> consoleConfigEntry : config.consoleHandlers.entrySet()) {
             ConsoleConfig namedConsoleConfig = consoleConfigEntry.getValue();
             if (!namedConsoleConfig.enable) {
                 continue;
             }
             final Handler consoleHandler = configureConsoleHandler(namedConsoleConfig, consoleRuntimeConfig, errorManager,
-                    filterElements,
+                    cleanupFilter,
                     possibleFormatters, null, launchMode);
             addToNamedHandlers(namedHandlers, consoleHandler, consoleConfigEntry.getKey());
         }
@@ -279,15 +286,15 @@ private static Map<String, Handler> createNamedHandlers(LogConfig config, Consol
             if (!namedFileConfig.enable) {
                 continue;
             }
-            final Handler fileHandler = configureFileHandler(namedFileConfig, errorManager, filterElements);
+            final Handler fileHandler = configureFileHandler(namedFileConfig, errorManager, cleanupFilter);
             addToNamedHandlers(namedHandlers, fileHandler, fileConfigEntry.getKey());
         }
         for (Entry<String, SyslogConfig> sysLogConfigEntry : config.syslogHandlers.entrySet()) {
             SyslogConfig namedSyslogConfig = sysLogConfigEntry.getValue();
             if (!namedSyslogConfig.enable) {
                 continue;
             }
-            final Handler syslogHandler = configureSyslogHandler(namedSyslogConfig, errorManager, filterElements);
+            final Handler syslogHandler = configureSyslogHandler(namedSyslogConfig, errorManager, cleanupFilter);
             if (syslogHandler != null) {
                 addToNamedHandlers(namedHandlers, syslogHandler, sysLogConfigEntry.getKey());
             }
@@ -341,7 +348,7 @@ public void initializeLoggingForImageBuild() {
 
     private static Handler configureConsoleHandler(final ConsoleConfig config, ConsoleRuntimeConfig consoleRuntimeConfig,
             final ErrorManager defaultErrorManager,
-            final List<LogCleanupFilterElement> filterElements,
+            final LogCleanupFilter cleanupFilter,
             final List<RuntimeValue<Optional<Formatter>>> possibleFormatters,
             final RuntimeValue<Optional<Supplier<String>>> possibleBannerSupplier, LaunchMode launchMode) {
         Formatter formatter = null;
@@ -384,7 +391,7 @@ private static Handler configureConsoleHandler(final ConsoleConfig config, Conso
                 config.stderr ? ConsoleHandler.Target.SYSTEM_ERR : ConsoleHandler.Target.SYSTEM_OUT, formatter);
         consoleHandler.setLevel(config.level);
         consoleHandler.setErrorManager(defaultErrorManager);
-        consoleHandler.setFilter(new LogCleanupFilter(filterElements));
+        consoleHandler.setFilter(cleanupFilter);
 
         Handler handler = config.async.enable ? createAsyncHandler(config.async, config.level, consoleHandler)
                 : consoleHandler;
@@ -421,7 +428,7 @@ public void close() throws SecurityException {
     }
 
     private static Handler configureFileHandler(final FileConfig config, final ErrorManager errorManager,
-            final List<LogCleanupFilterElement> filterElements) {
+            final LogCleanupFilter cleanupFilter) {
         FileHandler handler = new FileHandler();
         FileConfig.RotationConfig rotationConfig = config.rotation;
         if ((rotationConfig.maxFileSize.isPresent() || rotationConfig.rotateOnBoot)
@@ -454,7 +461,7 @@ private static Handler configureFileHandler(final FileConfig config, final Error
         }
         handler.setErrorManager(errorManager);
         handler.setLevel(config.level);
-        handler.setFilter(new LogCleanupFilter(filterElements));
+        handler.setFilter(cleanupFilter);
         if (config.async.enable) {
             return createAsyncHandler(config.async, config.level, handler);
         }
@@ -463,7 +470,7 @@ private static Handler configureFileHandler(final FileConfig config, final Error
 
     private static Handler configureSyslogHandler(final SyslogConfig config,
             final ErrorManager errorManager,
-            final List<LogCleanupFilterElement> filterElements) {
+            final LogCleanupFilter logCleanupFilter) {
         try {
             final SyslogHandler handler = new SyslogHandler(config.endpoint.getHostString(), config.endpoint.getPort());
             handler.setAppName(config.appName.orElse(getProcessName()));
@@ -478,7 +485,7 @@ private static Handler configureSyslogHandler(final SyslogConfig config,
             final PatternFormatter formatter = new PatternFormatter(config.format);
             handler.setFormatter(formatter);
             handler.setErrorManager(errorManager);
-            handler.setFilter(new LogCleanupFilter(filterElements));
+            handler.setFilter(logCleanupFilter);
             if (config.async.enable) {
                 return createAsyncHandler(config.async, config.level, handler);
             }

extensions/hibernate-reactive/deployment/pom.xml

@@ -73,7 +73,7 @@
         </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-resteasy-deployment</artifactId>
+            <artifactId>quarkus-resteasy-reactive-jsonb-deployment</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>

extensions/hibernate-reactive/deployment/src/test/java/io/quarkus/hibernate/reactive/dev/Fruit.java

@@ -0,0 +1,51 @@
+package io.quarkus.hibernate.reactive.dev;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.NamedQuery;
+import javax.persistence.SequenceGenerator;
+import javax.persistence.Table;
+
+@Entity
+@Table(name = "known_fruits")
+@NamedQuery(name = "Fruits.findAll", query = "SELECT f FROM Fruit f ORDER BY f.name")
+public class Fruit {
+
+    @Id
+    @SequenceGenerator(name = "fruitsSequence", sequenceName = "known_fruits_id_seq", allocationSize = 1, initialValue = 10)
+    @GeneratedValue(generator = "fruitsSequence")
+    private Integer id;
+
+    @Column(length = 40, unique = true)
+    private String name;
+
+    public Fruit() {
+    }
+
+    public Fruit(String name) {
+        this.name = name;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    @Override
+    public String toString() {
+        return "Fruit{" + id + "," + name + '}';
+    }
+}