diff --git a/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java b/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java
index c66e2ae..3cb4c2b 100644
--- a/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java
+++ b/src/main/java/com/techsor/datacenter/receiver/service/impl/MQTTServiceImpl.java
@@ -218,7 +218,7 @@ class MqttConsumer {
         }
 
         adapter.setCompletionTimeout(5000);
-        adapter.setRecoveryInterval(5000);
+//        adapter.set(5000);
         adapter.setConverter(new DefaultPahoMessageConverter());
         if (!Objects.nonNull(config.getQos())){
             adapter.setQos(1);