diff --git a/extensions/smallrye-reactive-messaging-mqtt/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/mqtt/deployment/MqttDevServicesProcessor.java b/extensions/smallrye-reactive-messaging-mqtt/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/mqtt/deployment/MqttDevServicesProcessor.java index de0e0d9084fdf..51b6d4d516e7f 100644 --- a/extensions/smallrye-reactive-messaging-mqtt/deployment/src/main/java/io/quarkus/smallrye/reactivemessaging/mqtt/deployment/MqttDevServicesProcessor.java +++ b/extensions/smallrye-reactive-messaging-mqtt/deployment/src/main/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;