An ORM for messages distributed with amqp capable message queues.