diff --git a/pkgs/service/msg_server.go b/pkgs/service/msg_server.go
index c4b7146..254651a 100644
--- a/pkgs/service/msg_server.go
+++ b/pkgs/service/msg_server.go
@@ -58,7 +58,11 @@ func (s *server) SubmitSnapshot(ctx context.Context, submission *pkgs.SnapshotSu
 	}
 	log.Debugln("Sending submission with ID: ", submissionId.String())
 
-	submissionBytes := append(submissionIdBytes, subBytes...)
+	submissionBytes := submissionIdBytes
+	if config.SettingsObj.DataMarketInRequest {
+		submissionBytes = append(submissionBytes, []byte(config.SettingsObj.DataMarketAddress)...)
+	}
+	submissionBytes = append(submissionBytes, subBytes...)
 
 	s.writeSemaphore <- struct{}{}
 	go func() {