pulsar write

2021-02-01 17:03:24 +08:00
parent 980c52c940
commit b9a826faf8
2 changed files with 7 additions and 4 deletions
@@ -70,6 +70,12 @@ func InsertTelegram(teleString string) {
 	db := getDb()
 	defer db.Close()
 	var insertSQL string
+	if Pulsar {
+		err := PulsarSend(teleString)
+		if err != nil {
+			Log.Error("error in send to pulsar", zap.Error(err))
+		}
+	}
 	if ClientReady && WriteToClient(teleString) == nil {
 		insertSQL = InsertOld
 	} else {