last fix...

andyxning · Dec 20, 2017 · b3f71ec · b3f71ec
1 parent f3fe32e
commit b3f71ec
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/conn.go b/conn.go
@@ -166,13 +166,9 @@ func (c *Conn) ConnectTTV2() (*IdentifyResponse, error) {
 	c.conn.SetReadDeadline(time.Now().Add(time.Second))
 	// TODO(andyxning): remove magic number
 	buf := make([]byte, 100)
-	count, err := c.conn.Read(buf)
+	_, err = c.conn.Read(buf)
 	if err == nil {
-		if strings.Contains(string(buf), "E_BAD_PROTOCOL") || string(buf[:count]) == "" {
-			return nil, ErrUnsupportedTTV2
-		}
-		c.log(LogLevelError, fmt.Sprintf("NSQD returns error: %v", string(buf)))
-		return nil, fmt.Errorf("NSQD returns error: %v", string(buf))
+		return nil, ErrUnsupportedTTV2
 	} else {
 		// TODO(andyxning): remove magic string
 		// because poll is an internal package and we can not reference poll.TimeoutError.