File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 11use  embedded_svc:: mqtt:: client:: { EventPayload ,  QoS } ; 
22use  esp_idf_svc:: mqtt:: client:: { EspMqttClient ,  EspMqttConnection ,  MqttClientConfiguration } ; 
33use  esp_idf_svc:: sys:: esp_crt_bundle_attach; 
4- use  log:: info ; 
4+ use  log:: * ; 
55use  std:: sync:: mpsc; 
66use  std:: thread; 
77use  std:: thread:: { sleep,  Scope ,  ScopedJoinHandle } ; 
@@ -37,7 +37,7 @@ pub fn spawn_receiver_thread<'scope>(
3737            info ! ( "[MQTT] Listening for messages" ) ; 
3838            while  let  Ok ( event)  = mqtt_connection. next ( )  { 
3939                let  payload = event. payload ( ) ; 
40-                 info ! ( "[MQTT] {}" ,  payload) ; 
40+                 debug ! ( "[MQTT] {}" ,  payload) ; 
4141                if  let  EventPayload :: Received  { 
4242                    id :  _, 
4343                    topic, 
@@ -51,7 +51,7 @@ pub fn spawn_receiver_thread<'scope>(
5151                    sleep ( Duration :: from_millis ( 500 ) ) 
5252                } 
5353            } 
54-             info ! ( "[MQTT] Connection closed" ) ; 
54+             error ! ( "[MQTT] Connection closed" ) ; 
5555        } ) 
5656} 
5757
@@ -61,7 +61,7 @@ pub fn try_until_subscribed(mqtt_client: &mut EspMqttClient, topic: &str) {
6161            sleep ( Duration :: from_millis ( 500 ) ) ; 
6262            continue ; 
6363        } 
64-         info ! ( "[MQTT] Subscribed to {topic}" ) ; 
64+         debug ! ( "[MQTT] Subscribed to {topic}" ) ; 
6565        break ; 
6666    } 
6767} 
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments