#NEWLINE# def _create_broadcast( self , database ) : #NEWLINE# #INDENT# 'Create capped collection for broadcast messages.' #NEWLINE# if ( self . broadcast_collection in database . collection_names ( ) ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# database . create_collection ( database . broadcast_collection , size = self . capped_queue_size , capped = True )