'Fetch any objects that have timed out
Args:
now (ms): Current time in msec
Returns:
list: List of objects that have timed out'

def fetch(self, now):

    now_key = int((now / self.bucket_size))
    ret = []
    while (self.entries and (self.entries[0].end_key <= now_key)):
        ret.extend(self.entries.pop(0).queue)
    return ret
