igds-api.git - Gitblit

			@@ -14,6 +14,9 @@

			@Autowired
			private MqttProperties mqttProperties;
			@Autowired
			private MqttConsumerCallBack mqttConsumerCallBack;

			/**
			* 客户端对象
			*/
			@@ -50,7 +53,8 @@
			//设置遗嘱消息的话题，若客户端和服务器之间的连接意外断开，服务器将发布客户端的遗嘱信息
			options.setWill("willTopic", (mqttProperties.getClientInId() + "与服务器断开连接").getBytes(), 0, false);
			//设置回调
			client.setCallback(new MqttConsumerCallBack());
			// client.setCallback(new MqttConsumerCallBack());
			client.setCallback(mqttConsumerCallBack);
			client.connect(options);
			//订阅主题
			//消息等级，和主题数组一一对应，服务端将按照指定等级给订阅了主题的客户端推送消息