Fixed amqp multiple file consumer problem.