def _create_broadcast(self, database):
        if self.broadcast_collection in database.collection_names():
            return

        database.create_collection(self.broadcast_collection,
                                   size=self.capped_queue_size,
                                   capped=True)
Create capped collection for broadcast messages.
dataset/ETHPy150Open celery/kombu/kombu/transport/mongodb.py/Channel._create_broadcast