'Load the contents of the provided fobj into the queue.'

def load(self, fobj):

    try:
        while True:
            val = self._pack(self.serializer.load(fobj))
            self.redis.lpush(self.key, val)
    except Exception:
        return
