#NEWLINE# def _update_queues_expire( self , queue ) : #NEWLINE# #INDENT# 'Updates expiration field on queues documents.' #NEWLINE# expire_at = self . _get_expire ( queue , 'x-expires' ) #NEWLINE# if ( not expire_at ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# self . routing . update ( { #NEWLINE# #INDENT# 'queue' : expire_at , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# '$set' : { #NEWLINE# #INDENT# 'expire_at' : expire_at , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } , multiple = True ) #NEWLINE# self . queues . update ( { #NEWLINE# #INDENT# '_id' : queue , #NEWLINE# #UNINDENT# } , { #NEWLINE# #INDENT# '$set' : { #NEWLINE# #INDENT# 'expire_at' : expire_at , #NEWLINE# #UNINDENT# } , #NEWLINE# #UNINDENT# } , multiple = True )