#NEWLINE# def _get_broadcast_cursor( self , queue ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# return self . _broadcast_cursors [ queue ] #NEWLINE# #UNINDENT# except KeyError : #NEWLINE# #INDENT# return self . _create_broadcast_cursor ( self . _fanout_queues [ queue ] , None , None , queue )