mirror of
https://github.com/emqx/neuron.git
synced 2026-10-18 13:41:22 +08:00
Merge pull request #797 from gc87/mqtt-fix-nonuser-login-v2.2
[v2.2]fix(mqtt): non-user login to rabbitmq auth failed
This commit is contained in:
@@ -509,9 +509,19 @@ static void client_reconnect(struct mqtt_client *mqtt, void **p_reconnect_state)
|
||||
const char *will_payload = state->will_payload;
|
||||
size_t payload_len = state->will_payload_len;
|
||||
|
||||
enum MQTTErrors rc = mqtt_connect(
|
||||
mqtt, client_id, will_topic, will_payload, payload_len, state->username,
|
||||
state->password, connect_flags, state->keepalive);
|
||||
char *username = NULL;
|
||||
if (NULL != state->username && 0 < strlen(state->username)) {
|
||||
username = state->username;
|
||||
}
|
||||
|
||||
char *password = NULL;
|
||||
if (NULL != state->password && 0 < strlen(state->password)) {
|
||||
password = state->password;
|
||||
}
|
||||
|
||||
enum MQTTErrors rc =
|
||||
mqtt_connect(mqtt, client_id, will_topic, will_payload, payload_len,
|
||||
username, password, connect_flags, state->keepalive);
|
||||
|
||||
if (MQTT_OK != rc) {
|
||||
return;
|
||||
|
||||
Reference in New Issue
Block a user