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

Fix MQTT synchronization for recoveryInterval

Browse Source
This commit is contained in:
Gary Russell
2018-10-26 16:42:48 -04:00
parent 2b1976ce6f
commit c594e75616
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/inbound/MqttPahoMessageDrivenChannelAdapter.java
View File

@@ -57,9 +57,9 @@ public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDriv
private final MqttPahoClientFactory clientFactory;
private volatile long completionTimeout = DEFAULT_COMPLETION_TIMEOUT;
private int recoveryInterval = DEFAULT_RECOVERY_INTERVAL;
private volatile int recoveryInterval = DEFAULT_RECOVERY_INTERVAL;
private volatile long completionTimeout = DEFAULT_COMPLETION_TIMEOUT;
private volatile IMqttClient client;
@@ -128,7 +128,7 @@ public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDriv
* @param recoveryInterval the interval.
* @since 4.2.2
*/
public void setRecoveryInterval(int recoveryInterval) {
public synchronized void setRecoveryInterval(int recoveryInterval) {
this.recoveryInterval = recoveryInterval;
}