app/models/agents/mqtt_agent.rb

@@ -109,7 +109,7 @@ module Agents

                     def receive(incoming_events)
              

                       mqtt_client.connect do |c|
              

                         incoming_events.each do |event|
              

                -          c.publish(interpolated(event)['topic'], event.payload)
              

                +          c.publish(interpolated(event)['topic'], event.payload['message'])
              

                         end
              

                       end
              

                     end