1.主题订阅机制-不能使用原始的sub，需要使用emqkeeper的包装后的

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/AmosTzsApplication.java

@@ -102,13 +102,13 @@ public class AmosTzsApplication {
 	 * @throws MqttException
 	 */
 	@Bean
-	public void initMqtt() throws MqttException {
-		emqKeeper.getMqttClient().subscribe("/idx/idx_biz_carcyl_unit_inspect", 1, carcylUnitInspectMqTtlListener);
-		emqKeeper.getMqttClient().subscribe("/tm/tz_base_enterprise_info", 1, baseEnterpriseMqTtlListener);
-		emqKeeper.getMqttClient().subscribe("/tz/privilege_company_add_update", 1, privilegeCompanyUpdateAddListener);
-		emqKeeper.getMqttClient().subscribe("/tz/privilege_company_delete", 1, privilegeCompanyDeleteListener);
-		emqKeeper.getMqttClient().subscribe("/tzs/sync/fillingRecord", 1, fillingRecordSyncListener);
-		emqKeeper.getMqttClient().subscribe("tzs/oneCodePass/deviceSave", 0, amosMqTtlListener);
+	public void initMqtt() throws Exception {
+		emqKeeper.subscript("/idx/idx_biz_carcyl_unit_inspect", 2, carcylUnitInspectMqTtlListener);
+		emqKeeper.subscript("/tm/tz_base_enterprise_info", 2, baseEnterpriseMqTtlListener);
+		emqKeeper.subscript("/tz/privilege_company_add_update", 2, privilegeCompanyUpdateAddListener);
+		emqKeeper.subscript("/tz/privilege_company_delete", 2, privilegeCompanyDeleteListener);
+		emqKeeper.subscript("/tzs/sync/fillingRecord", 2, fillingRecordSyncListener);
+		emqKeeper.subscript("tzs/oneCodePass/deviceSave", 2, amosMqTtlListener);
 //		emqKeeper.getMqttClient().subscribe("topic_mqtt_exam", 1, examMqTtlListener);
 //		emqKeeper.getMqttClient().subscribe("topic_mqtt_exam_record", 1, examMqTtRecordListener);
 	}