A Cloudify specific transport to consume logs/events from RMQ and push them to PostgreSQL.

This is a Cloudify Manager internal component and should not be used separately.