Temporarily add `message` field

2019-10-23 15:03:09 -05:00 · 2019-10-23 15:03:09 -05:00 · b66731a1f4
parent 0bbcc8c786
commit b66731a1f4
1 changed files with 4 additions and 1 deletions
--- a/app/lib/telemetry_service.rb
+++ b/app/lib/telemetry_service.rb
@ -10,6 +10,9 @@ class TelemetryService < AbstractServiceRunner
  def process(delivery_info, payload)
    device_key = delivery_info.routing_key.split(".")[1]
    json = JSON.parse(payload)
-    puts json.merge(device: device_key, is_telemetry: true).to_json
+    other_stuff = { device: device_key,
+                    is_telemetry: true,
+                    message: "TELEMETRY MESSAGE FROM #{device_key}" }
+    puts json.merge(other_stuff).to_json
  end
 end