From 1277531290fce090a38edb976e604d39ed225be6 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 28 Feb 2020 10:37:40 -0500 Subject: [PATCH] Fix Sonar issue --- .../integration/mqtt/outbound/MqttPahoMessageHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java index fb93564233..5ed6c41732 100644 --- a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java +++ b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java @@ -135,7 +135,7 @@ public class MqttPahoMessageHandler extends AbstractMqttMessageHandler * @since 4.1 */ public void setCompletionTimeout(long completionTimeout) { - this.completionTimeout = completionTimeout; + this.completionTimeout = completionTimeout; // NOSONAR (sync) } /** @@ -145,7 +145,7 @@ public class MqttPahoMessageHandler extends AbstractMqttMessageHandler * @since 5.1.10 */ public void setDisconnectCompletionTimeout(long completionTimeout) { - this.disconnectCompletionTimeout = completionTimeout; + this.disconnectCompletionTimeout = completionTimeout; // NOSONAR (sync) } @Override @@ -214,7 +214,7 @@ public class MqttPahoMessageHandler extends AbstractMqttMessageHandler IMqttDeliveryToken token = checkConnection() .publish(topic, (MqttMessage) mqttMessage); if (!this.async) { - token.waitForCompletion(this.completionTimeout); + token.waitForCompletion(this.completionTimeout); // NOSONAR (sync) } else if (this.asyncEvents && this.applicationEventPublisher != null) { this.applicationEventPublisher.publishEvent(