|
|
|
@ -60,11 +60,11 @@ public class MqttConfigHzims {
|
|
|
|
|
log.info(fdpClient.toString()+fdpClient.getClientId()); |
|
|
|
|
//drools
|
|
|
|
|
DroolsSoeSubscribe droolsSoeSubscribe = new DroolsSoeSubscribe(); |
|
|
|
|
MqttAsyncClient droolsClient = droolsSoeSubscribe.subscribe(mqttConfig, "#",Collections.singletonList("#"), droolsMqttConsumer); |
|
|
|
|
MqttAsyncClient droolsClient = droolsSoeSubscribe.subscribe(mqttConfig, Collections.singletonList("#"), droolsMqttConsumer); |
|
|
|
|
log.info(droolsClient.toString()+droolsClient.getClientId()); |
|
|
|
|
//Soe
|
|
|
|
|
SoeSubscribe soeSubscribe = new SoeSubscribe(); |
|
|
|
|
MqttAsyncClient soeClient = soeSubscribe.subscribe(mqttConfig, "#",Collections.singletonList("#"), soeMqttConsumer); |
|
|
|
|
MqttAsyncClient soeClient = soeSubscribe.subscribe(mqttConfig, Collections.singletonList("#"), soeMqttConsumer); |
|
|
|
|
log.info(soeClient.toString()+soeClient.getClientId()); |
|
|
|
|
//hz3000
|
|
|
|
|
HZ3000SoeSubscribe hz3000SoeSubscribe = new HZ3000SoeSubscribe(); |
|
|
|
@ -72,7 +72,7 @@ public class MqttConfigHzims {
|
|
|
|
|
log.info(hz3000Client.toString()+hz3000Client.getClientId()); |
|
|
|
|
//视频
|
|
|
|
|
SoeSubscribe subscribe = new SoeSubscribe(); |
|
|
|
|
MqttAsyncClient videoClient = subscribe.subscribe(mqttConfig, "#",Collections.singletonList("#"), videoMqttConsumer); |
|
|
|
|
MqttAsyncClient videoClient = subscribe.subscribe(mqttConfig, Collections.singletonList("#"), videoMqttConsumer); |
|
|
|
|
log.info(videoClient.toString()+videoClient.getClientId()); |
|
|
|
|
}catch (Exception e){ |
|
|
|
|
log.error(e.toString()) ; |
|
|
|
|