| 
					
				 | 
			
			
				@ -58,7 +58,8 @@ public class MQTTClientUtil { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                public void messageArrived(String s, MqttMessage message) throws Exception { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    // subscribe后得到的消息会执行到这里面 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    logger.info("接收消息主题 : " + TOPIC); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    logger.info("接收s : " + s); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    logger.info("接收消息主题 : " + message); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    logger.info("接收消息Qos : " + message.getQos()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    logger.info("接收消息内容 : " + new String(message.getPayload())); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 |