WS: use of closed network connection

[MarcMagnin]

Hi,

I'd like to use the WS connection but I got the following errors when connecting up (broker output):

Time:2018-01-16 17:48:12        file:client.go  level:ERROR     read packet error: read tcp 127.0.0.1:1888->127.0.0.1:35916: use of closed network connection clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f
Time:2018-01-16 17:48:12        file:client.go  level:DEBUG     Recv message: DISCONNECT: dup: false qos: 0 retain: false rLength: 0 clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f
Time:2018-01-16 17:48:12        file:broker.go  level:WARN      client exist, close old... clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f
Time:2018-01-16 17:48:12        file:client.go  level:DEBUG     Recv message: DISCONNECT: dup: false qos: 0 retain: false rLength: 0 clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f
Time:2018-01-16 17:48:12        file:client.go  level:ERROR     read packet error: read tcp 127.0.0.1:1888->127.0.0.1:35918: use of closed network connection clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f
Time:2018-01-16 17:48:12        file:client.go  level:DEBUG     Recv message: DISCONNECT: dup: false qos: 0 retain: false rLength: 0 clientID = f27c46e3-8d81-4b62-b405-e9b5b2149f9f

I'm connecting using the pahoMQTT client like the following:

opts := pahoMQTT.NewClientOptions()
opts.AddBroker("ws://0.0.0.0:1888/ws")
opts.SetClientID("client-test")
opts.SetKeepAlive(time.Duration(120 * time.Second))
opts.SetConnectTimeout(time.Duration(5 * time.Second))

mqttClient := pahoMQTT.NewClient(opts)
token := mqttClient.Connect()
if token.WaitTimeout(time.Duration(5000*time.Millisecond)) || token.Error() != nil {
	log.Panic("Unable to connect to MQTT. ", token.Error())
}

Btw token.Error() == nil

Many thanks.

[chowyu08]

I have fix this, please clone the newest code, thanks