cache messages for a short time and send as a package

alpha v1.0.54
alex 2023-02-19 19:29:08 +01:00
parent 7881cff4bd
commit 88f4c0692f
1 changed files with 0 additions and 14 deletions

View File

@ -167,8 +167,6 @@ func startLogMessagesSender() {
ticker := time.NewTicker(time.Millisecond * 500)
for range ticker.C {
log.Print("tick")
msgs := getLogMessages()
if len(msgs) == 0 {
@ -204,17 +202,5 @@ func pushLogMessage(messageType uint8, logMsg string) {
Timestamp: time.Now().UnixMilli(),
}
/*
msg, err := json.Marshal(rabbitMqLogMessage)
if err != nil {
log.Error().Msgf("Failed to marshal rabbitMqLogMessage, err: %s", err)
return
} */
addLogMessage(rabbitMqLogMessage)
/*
if err = logsClient.PushQueueMessage(msg); err != nil {
log.Error().Msgf("Failed to push log message, err: %s", err)
} */
}