Track the number of messages going in and out of each consumer.

Could also be done as `self.headcount_out = self.headcount_in = 0` to avoid tuples expansion during assignment