Refactor consumer and producer implementations.

• Separate producer definition from consumers.
• Isolate AMQP functions within a manager to allow better testing.
• Add tests for basic consume and production.