'Create capped collection for broadcast messages.'

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)
