A Cloudify specific transport to consume events from RMQ and push them to InfluxDB