|
@@ -109,7 +109,7 @@ module Agents
|
|
def receive(incoming_events)
|
|
def receive(incoming_events)
|
|
mqtt_client.connect do |c|
|
|
mqtt_client.connect do |c|
|
|
incoming_events.each do |event|
|
|
incoming_events.each do |event|
|
|
- c.publish(interpolated(event)['topic'], event)
|
|
|
|
|
|
+ c.publish(interpolated(event)['topic'], event.payload)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|