FOUND IT HOLY SHIT YES
This commit is contained in:
parent
d30c6c9498
commit
a9caa1cb24
1 changed files with 0 additions and 6 deletions
|
@ -112,12 +112,6 @@ func HandleIncomingMessages(c echo.Context, pubsub pubsub.PubSubMessage, client
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Skip processing if the message payload is empty
|
|
||||||
if msg.Payload == "" {
|
|
||||||
LogInfo.Printf("Received empty message, skipping processing")
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
|
|
||||||
// Prepare the data string to be sent as an SSE
|
// Prepare the data string to be sent as an SSE
|
||||||
data := fmt.Sprintf("data: %s\n\n", msg.Payload)
|
data := fmt.Sprintf("data: %s\n\n", msg.Payload)
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue