| | |
|---|
| | | private String mqttClientId; |
|---|
| | | @Value(value = "${jeecg.mqtt.role}") |
|---|
| | | private String role; |
|---|
| | | @Value(value = "${jeecg.mqtt.enable}") |
|---|
| | | private boolean enable; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private MqttSampleCallback mqttSampleCallback; |
|---|
| | |
|---|
| | | * mqtt连接配置 |
|---|
| | | */ |
|---|
| | | private void conn() { |
|---|
| | | if (!isEnable()) return; |
|---|
| | | MemoryPersistence persistence = new MemoryPersistence(); |
|---|
| | | MqttConnectOptions mqttConnOpt = new MqttConnectOptions(); |
|---|
| | | mqttConnOpt.setUserName(mqttName); |
|---|
| | |
|---|
| | | |
|---|
| | | //重连 |
|---|
| | | private void reconn() { |
|---|
| | | if (!isEnable()) return; |
|---|
| | | Timer timer = new Timer(); |
|---|
| | | |
|---|
| | | TimerTask task = new TimerTask() { |
|---|
