tr-parking-sfhera: somewhat working skeleton

noi-techpark · Jul 3, 2024 · 5f6eca1 · 5f6eca1
1 parent 4e51729
commit 5f6eca1
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/transformers/parking-offstreet-sfhera/src/main.go b/transformers/parking-offstreet-sfhera/src/main.go
@@ -111,7 +111,11 @@ func main() {
 
 			dm := b.CreateDataMap()
 			dm.AddRecord(s.Id, dtFree.Name, bdplib.CreateRecord(raw.Timestamp.UnixMilli(), payload.Tot, 300))
-			b.PushData(ParkingStation, dm)
+			if err := b.PushData(ParkingStation, dm); err != nil {
+				slog.Error("Error pushing data to bdp", "err", err, "msg", m)
+				msgReject(&d)
+				continue
+			}
 
 			failOnError(d.Nack(false, true), "Could not ACK elaborated msg")