Update hive.go (#77)

beltran · Dec 5, 2019 · a092d93 · a092d93
1 parent 556489f
commit a092d93
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/hive.go b/hive.go
@@ -163,8 +163,10 @@ func Connect(host string, port int, auth string,
 		} else {
 			panic("Unrecognized auth")
 		}
-		if err = transport.Open(); err != nil {
-			return
+		if !transport.IsOpen() {
+			if err = transport.Open(); err != nil {
+				return
+			}
 		}
 	} else {
 		panic(fmt.Sprintf("Unrecognized transport mode %s", configuration.TransportMode))