diff --git a/datastreamer/streamrelay.go b/datastreamer/streamrelay.go
index cc900ec..4882678 100644
--- a/datastreamer/streamrelay.go
+++ b/datastreamer/streamrelay.go
@@ -50,6 +50,13 @@ func (r *StreamRelay) Start() error {
 	}
 	r.server.initEntry = r.client.Header.TotalEntries
 
+	// Start server side before exec command `CmdStart`
+	err = r.server.Start()
+	if err != nil {
+		log.Errorf("Error starting relay server: %v", err)
+		return err
+	}
+
 	// Sync with master server from latest received entry
 	r.client.FromEntry = r.server.GetHeader().TotalEntries
 	log.Infof("TotalEntries: RELAY %d of MASTER %d", r.client.FromEntry, r.server.initEntry)
@@ -59,13 +66,6 @@ func (r *StreamRelay) Start() error {
 		return err
 	}
 
-	// Start server side
-	err = r.server.Start()
-	if err != nil {
-		log.Errorf("Error starting relay server: %v", err)
-		return err
-	}
-
 	return nil
 }