From c594e75616d473d39b09dae9296f1fe587f5c211 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 26 Oct 2018 16:42:48 -0400 Subject: [PATCH] Fix MQTT synchronization for recoveryInterval --- .../mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java index 4b5615dccf..ef7ab3fdac 100644 --- a/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java +++ b/spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java @@ -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; }