From b973e854da94a0583fdede72292c45b97d8fdbfe Mon Sep 17 00:00:00 2001 From: Pablo Gonzalez Granados Date: Wed, 15 Nov 2023 16:46:05 +0100 Subject: [PATCH] Fix MQTT devService always start even if the host/port channel is set --- .../mqtt/deployment/MqttDevServicesProcessor.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) 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;