Consume the messages published by pooling_spec