1、回退参数
This commit is contained in:
parent
f90c61c676
commit
c82f87c3dc
@ -27,7 +27,7 @@ import java.util.List;
|
|||||||
@Configuration
|
@Configuration
|
||||||
@EnableScheduling
|
@EnableScheduling
|
||||||
public class ZNYMQTTForwarder extends Forwarder {
|
public class ZNYMQTTForwarder extends Forwarder {
|
||||||
static final String FORWARDER_NAME = "贵州交勘院MQTT";
|
static final String FORWARDER_NAME = "中南院MQTT";
|
||||||
@Value("${zny.mqtt.brokerUrl}")
|
@Value("${zny.mqtt.brokerUrl}")
|
||||||
private String brokerUrl;
|
private String brokerUrl;
|
||||||
@Value("${zny.mqtt.username}")
|
@Value("${zny.mqtt.username}")
|
||||||
@ -45,9 +45,9 @@ public class ZNYMQTTForwarder extends Forwarder {
|
|||||||
|
|
||||||
@PostConstruct
|
@PostConstruct
|
||||||
void registerMe() throws MqttException {
|
void registerMe() throws MqttException {
|
||||||
init(FORWARDER_NAME, "MQTT "+brokerUrl,2,FWD_DEVICE_ALIAS_NAME,30);
|
//init(FORWARDER_NAME, "MQTT "+brokerUrl,4,FWD_DEVICE_ALIAS_NAME,30);
|
||||||
mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
|
mqttClient = new MQTTClient(brokerUrl, username, password,clientid);
|
||||||
mqttClient.connect();
|
//mqttClient.connect();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user