initial amqp implementation