update

broker/client.go

@@ -109,6 +109,8 @@ func (c *client) readLoop() {
 			//add read timeout
 			if err := nc.SetReadDeadline(time.Now().Add(timeOut)); err != nil {
 				log.Error("set read timeout error: ", zap.Error(err), zap.String("ClientID", c.info.clientID))
+				msg := &Message{client: c, packet: DisconnectdPacket}
+				b.SubmitWork(c.info.clientID, msg)
 				return
 			}
 

plugins/authhttp/authhttp.go

@@ -2,6 +2,7 @@ package authhttp
 
 import (
 	"encoding/json"
+	"fmt"
 	"io/ioutil"
 	"net/http"
 	"net/url"
@@ -43,6 +44,7 @@ func Init() {
 	if err != nil {
 		log.Fatal("Unmarshal config file error: ", zap.Error(err))
 	}
+	fmt.Println("http: config: ", config)
 
 	httpClient = &http.Client{
 		Transport: &http.Transport{