Pahoで、ForceDisconnectメソッドが削除されたため、それに合わせて修正。

takanorig · Aug 1, 2015 · 66e01e4 · 66e01e4
1 parent b32dea4
commit 66e01e4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mqtt-bench.go b/mqtt-bench.go
@@ -290,7 +290,7 @@ func AsyncDisconnect(clients []*MQTT.Client) {
 
 // Brokerとの接続を切断する。
 func Disconnect(client *MQTT.Client) {
-	client.ForceDisconnect()
+	client.Disconnect(10)
 }
 
 func main() {