Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Sonar issue

Browse Source
This commit is contained in:
Gary Russell
2020-02-28 10:37:40 -05:00
parent 0e5258a661
commit 1277531290
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java
View File

@@ -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(