|
|
@@ -64,8 +64,8 @@ func TestMqttBinding(t *testing.T) {
|
|
|
SetPassword("mtyzxhc").
|
|
|
AddBroker("tcp://127.0.0.1:1883").
|
|
|
SetClientID("test-client").
|
|
|
- SetKeepAlive(5).
|
|
|
- SetPingTimeout(5).
|
|
|
+ SetKeepAlive(5*time.Second).
|
|
|
+ SetPingTimeout(5*time.Second).
|
|
|
SetWill("test-client/will", "dead", 2, true).
|
|
|
SetOnConnectHandler(func(client mqtt.Client) {
|
|
|
token := client.Subscribe("test_prefix/test/test-topic/reply", 2, func(client mqtt.Client, message mqtt.Message) {
|
