Merge branch 'main' into better-client-error

metacosm · Nov 30, 2023 · 65e1dac · 65e1dac
2 parents aab426e + 07ca9f7
commit 65e1dac
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/.../java/io/quarkus/smallrye/reactivemessaging/mqtt/deployment/MqttDevServicesProcessor.java b/.../java/io/quarkus/smallrye/reactivemessaging/mqtt/deployment/MqttDevServicesProcessor.java
@@ -203,17 +203,16 @@ private boolean hasMqttChannelWithoutHostAndPort() {
             boolean isIncoming = name.startsWith("mp.messaging.incoming.");
             boolean isOutgoing = name.startsWith("mp.messaging.outgoing.");
             boolean isConnector = name.endsWith(".connector");
-            boolean isConfigured = false;
+            boolean isConfigured;
             if ((isIncoming || isOutgoing) && isConnector) {
                 String connectorValue = config.getValue(name, String.class);
                 boolean isMqtt = connectorValue.equalsIgnoreCase("smallrye-mqtt");
                 boolean hasHost = ConfigUtils.isPropertyPresent(name.replace(".connector", ".host"));
                 boolean hasPort = ConfigUtils.isPropertyPresent(name.replace(".connector", ".port"));
                 isConfigured = isMqtt && (hasHost || hasPort);
-            }
-
-            if (!isConfigured) {
-                return true;
+                if (!isConfigured) {
+                    return true;
+                }
             }
         }
         return false;