'Update expiration field on queues documents.'

def _update_queues_expire(self, queue):

    expire_at = self._get_expire(queue, u'x-expires')
    if (not expire_at):
        return
    self.routing.update({u'queue': queue}, {u'$set': {u'expire_at': expire_at}}, multiple=True)
    self.queues.update({u'_id': queue}, {u'$set': {u'expire_at': expire_at}}, multiple=True)
