diff --git a/exchanges/stream/websocket.go b/exchanges/stream/websocket.go
index 8632cba3..1b674a4b 100644
--- a/exchanges/stream/websocket.go
+++ b/exchanges/stream/websocket.go
@@ -261,12 +261,14 @@ func (w *Websocket) Connect() error {
 	w.setConnectingStatus(false)
 	w.setInit(true)
 
-	err = w.connectionMonitor()
-	if err != nil {
-		log.Errorf(log.WebsocketMgr,
-			"%s cannot start websocket connection monitor %v",
-			w.GetName(),
-			err)
+	if !w.IsConnectionMonitorRunning() {
+		err = w.connectionMonitor()
+		if err != nil {
+			log.Errorf(log.WebsocketMgr,
+				"%s cannot start websocket connection monitor %v",
+				w.GetName(),
+				err)
+		}
 	}
 
 	subs, err := w.GenerateSubs() // regenerate state on new connection