added actual amqp code - consumer dies regularly with a panic now :(