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

Could be minimized to `self.headcount_in += 1` :neckbeard: