Избегаем "залипания" последнего сообщения в MQTT. master
authorRoman Bazalevsky <rvb@rvb.name>
Mon, 24 Dec 2018 08:14:12 +0000 (11:14 +0300)
committerRoman Bazalevsky <rvb@rvb.name>
Mon, 24 Dec 2018 08:14:12 +0000 (11:14 +0300)
mqtt-bt/scan-beacons

index d6d0d26f0006f64c68ca5a2afe6561c39a08b607..5512aa9a009aa3c03531ba19c217c41687e0e5a3 100644 (file)
@@ -98,10 +98,7 @@ end
 function printLog(str)
   if logging=="yes" then
     capture("logger -t beaconmon \""..str.."\"")
 function printLog(str)
   if logging=="yes" then
     capture("logger -t beaconmon \""..str.."\"")
-    print(str)  
-  elseif logging=="syslog" then
-    capture("logger -t beaconmon \""..str.."\"")
-  elseif logging=="stdout" then 
+  else 
     print(str)  
   end 
 end
     print(str)  
   end 
 end
@@ -138,7 +135,7 @@ local function starts_with(str, start)
 end
 
 function mqtt_pub(path,value)
 end
 
 function mqtt_pub(path,value)
-  res=mqtt_client:publish(path,value)
+  res=mqtt_client:publish(path,value,0,false)
   printLog("Pub "..path.." returned "..res);
   return res
 end
   printLog("Pub "..path.." returned "..res);
   return res
 end
@@ -186,7 +183,7 @@ function process_packet(packet)
         
     if not pcall(mqtt_pub,mqtt_path,dump(packet)) then
       printLog('Reconnecting MQTT...')
         
     if not pcall(mqtt_pub,mqtt_path,dump(packet)) then
       printLog('Reconnecting MQTT...')
-      mqtt_client:connect(mqtt_id)
+      mqtt_client:connect(mqtt_host,mqtt_port)
     end
 
   end
     end
 
   end