Skip to content

Commit 1277531

Browse files
committed
Fix Sonar issue
1 parent 0e5258a commit 1277531

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

+3-3
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ public void setAsyncEvents(boolean asyncEvents) {
135135
* @since 4.1
136136
*/
137137
public void setCompletionTimeout(long completionTimeout) {
138-
this.completionTimeout = completionTimeout;
138+
this.completionTimeout = completionTimeout; // NOSONAR (sync)
139139
}
140140

141141
/**
@@ -145,7 +145,7 @@ public void setCompletionTimeout(long completionTimeout) {
145145
* @since 5.1.10
146146
*/
147147
public void setDisconnectCompletionTimeout(long completionTimeout) {
148-
this.disconnectCompletionTimeout = completionTimeout;
148+
this.disconnectCompletionTimeout = completionTimeout; // NOSONAR (sync)
149149
}
150150

151151
@Override
@@ -214,7 +214,7 @@ protected void publish(String topic, Object mqttMessage, Message<?> message) {
214214
IMqttDeliveryToken token = checkConnection()
215215
.publish(topic, (MqttMessage) mqttMessage);
216216
if (!this.async) {
217-
token.waitForCompletion(this.completionTimeout);
217+
token.waitForCompletion(this.completionTimeout); // NOSONAR (sync)
218218
}
219219
else if (this.asyncEvents && this.applicationEventPublisher != null) {
220220
this.applicationEventPublisher.publishEvent(

0 commit comments

Comments
 (0)