mirror of
https://github.com/mainflux/mainflux.git
synced 2025-04-26 13:48:53 +08:00
1810cec82b
* Fix MQTT Forwarder client ID Don't set client ID for MQTT client in MQTT forwarder. It results in error in case of multiple instances of the MQTT adapter because they all share MQTT client ID, which makes broker disconnect all the other adapters. Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com> * Inline broker address option Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com> * Add MQTT client username Signed-off-by: dusanb94 <dusan.borovcanin@mainflux.com> Co-authored-by: Drasko DRASKOVIC <drasko.draskovic@gmail.com>
41 lines
726 B
Go
41 lines
726 B
Go
// Copyright (c) Mainflux
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package mqtt
|
|
|
|
import (
|
|
"errors"
|
|
"time"
|
|
|
|
mqtt "github.com/eclipse/paho.mqtt.golang"
|
|
)
|
|
|
|
const (
|
|
protocol = "mqtt"
|
|
username = "mainflux-mqtt"
|
|
qos = 2
|
|
)
|
|
|
|
var errConnect = errors.New("failed to connect to MQTT broker")
|
|
|
|
func newClient(address string, timeout time.Duration) (mqtt.Client, error) {
|
|
opts := mqtt.NewClientOptions().
|
|
SetUsername(username).
|
|
AddBroker(address)
|
|
client := mqtt.NewClient(opts)
|
|
token := client.Connect()
|
|
if token.Error() != nil {
|
|
return nil, token.Error()
|
|
}
|
|
|
|
ok := token.WaitTimeout(timeout)
|
|
if ok && token.Error() != nil {
|
|
return nil, token.Error()
|
|
}
|
|
if !ok {
|
|
return nil, errConnect
|
|
}
|
|
|
|
return client, nil
|
|
}
|